Thanks Rong
This worked.
$FLINK_HOME/bin/start-scala-shell.sh local --addclasspath
/home/hduser/jars/flink-connector-kafka-0.9_2.11-1.5.0.jar:/home/hduser/jars/flink-connector-kafka-base_2.11-1.5.0.jar
Regards,
Dr Mich Talebzadeh
LinkedIn *
https://www.linkedin.com/profile/view?id=AAEW
Hi Mich,
Ted is correct, Flink release binary does not include any connectors and
you will have to include the appropriate connector version. This is to
avoid dependency conflicts between different Kafka releases.
You probably need the specific Kafka connector version jar file as well, so
in your
Please add flink-connector-kafka-base_2.11 jar to the classpath.
On Sat, Jun 30, 2018 at 1:06 AM, Mich Talebzadeh
wrote:
>
> Great Ted added that jar file to the classpath
>
> Running this code
>
> import org.apache.flink.streaming.api.scala._
> import org.apache.flink.streaming.connectors.kafka
