flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mich Talebzadeh <mich.talebza...@gmail.com>
Subject Testing Kafka interface using Flink interactive shell
Date Sun, 17 Apr 2016 09:04:47 GMT

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

spark-shell --master spark:// --jars

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
            import org.apache.flink.streaming.connectors.kafka

Any ideas will be appreciated

Dr Mich Talebzadeh

LinkedIn * https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw


View raw message