One thing to add: Flink 1.2.0 has not been release yet. The FlinkKafkaConsumer010 is only available in a SNAPSHOT release or the first release candidate (RC0).
Best, Fabian 2017-01-17 16:08 GMT+01:00 Timo Walther <twal...@apache.org>: > You are using an old version of Flink (0.10.2). A FlinkKafkaConsumer010 > was not present at that time. You need to upgrade to Flink 1.2. > > Timo > > > Am 17/01/17 um 15:58 schrieb Neil Derraugh: > > This is really a Zeppelin question, and I’ve already posted to the user >> list there. I’m just trying to draw in as many relevant eyeballs as >> possible. If you can help please reply on the Zeppelin mailing list. >> >> In my Zeppelin notebook I’m having a problem importing the Kafka >> streaming library for Flink. >> >> I added org.apache.flink:flink-connector-kafka_2.11:0.10.2 to the >> Dependencies on the Flink interpreter. >> >> The Flink interpreter runs code, just not if I have the following import. >> import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010 >> >> I get this error: >> <console>:72: error: object FlinkKafkaConsumer010 is not a member of >> package org.apache.flink.streaming.connectors.kafka >> import org.apache.flink.streaming.con >> nectors.kafka.FlinkKafkaConsumer010 >> >> Am I doing something wrong here? >> >> Neil >> > > >
