Testing Kafka interface using Flink interactive shell

Posted by Mich Talebzadeh on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Testing-Kafka-interface-using-Flink-interactive-shell-tp6141.html

Hi,

IN Spark shell I can load Kafka jar file through spark-shell option --jar

spark-shell --master spark://50.140.197.217:7077 --jars ,/home/hduser/jars/spark-streaming-kafka-assembly_2.10-1.6.1.jar

This works fine.

In Flink I have added the jar file /home/hduser/jars/flink-connector-kafka-0.10.1.jar to the CLASSPATH.

However I don't get any support for it within flink shell

Scala-Flink> import org.apache.flink.streaming.connectors.kafka
<console>:54: error: object connectors is not a member of package org.apache.flink.streaming
            import org.apache.flink.streaming.connectors.kafka

Any ideas will be appreciated

                                              ^