Are connectors being included in the 1.2.0 release or do you mean Kafka specifically?
From: Fabian Hueske <fhue...@gmail.com> Reply-To: "user@flink.apache.org" <user@flink.apache.org> Date: Tuesday, January 17, 2017 at 7:10 AM To: "user@flink.apache.org" <user@flink.apache.org> Subject: Re: Zeppelin: Flink Kafka Connector 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<mailto: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.connectors.kafka.FlinkKafkaConsumer010 Am I doing something wrong here? Neil
