The connectors are included in the release and available as individual Maven artifacts. So Flink 1.2.0 will provide a flink-connector-kafka-0.10 artifact (with version 1.2.0).
2017-01-17 16:22 GMT+01:00 Foster, Craig <foscr...@amazon.com>: > 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>: > > 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 > > > > >
