Re: Zeppelin: Flink Kafka Connector

2017-01-18 Thread Fabian Hueske
Ah, OK :-) Thanks for reporting back! Cheers, Fabian 2017-01-17 17:50 GMT+01:00 Neil Derraugh < neil.derra...@intellifylearning.com>: > I re-read that enough times and it finally made sense. I wasn’t paying > attention and thought 0.10.2 was the Kafka version —which hasn’t been > released yet ei

Re: Zeppelin: Flink Kafka Connector

2017-01-17 Thread Neil Derraugh
I re-read that enough times and it finally made sense. I wasn’t paying attention and thought 0.10.2 was the Kafka version —which hasn’t been released yet either - ha :(. I switched to a recent version and it’s all good. :) Thanks ! Neil > On Jan 17, 2017, at 11:14 AM, Neil Derraugh > wrote:

Re: Zeppelin: Flink Kafka Connector

2017-01-17 Thread Neil Derraugh
Hi Timo & Fabian, Thanks for replying. I'm using Zeppelin built off master. And Flink 1.2 built off the release-1.2 branch. Is that the right branch? Neil -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Zeppelin-Flink-Kafka-Connector-tp1

Re: Zeppelin: Flink Kafka Connector

2017-01-17 Thread Fabian Hueske
fka > specifically? > > > > *From: *Fabian Hueske > *Reply-To: *"user@flink.apache.org" > *Date: *Tuesday, January 17, 2017 at 7:10 AM > *To: *"user@flink.apache.org" > *Subject: *Re: Zeppelin: Flink Kafka Connector > > > >

Re: Zeppelin: Flink Kafka Connector

2017-01-17 Thread Foster, Craig
Are connectors being included in the 1.2.0 release or do you mean Kafka specifically? From: Fabian Hueske Reply-To: "user@flink.apache.org" Date: Tuesday, January 17, 2017 at 7:10 AM To: "user@flink.apache.org" Subject: Re: Zeppelin: Flink Kafka Connector One thing to

Re: Zeppelin: Flink Kafka Connector

2017-01-17 Thread Fabian Hueske
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 : > You are using an old version of Flink (0.10.2). A FlinkKafkaConsumer010 > was n

Re: Zeppelin: Flink Kafka Connector

2017-01-17 Thread Timo Walther
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 dra