Re: Zeppelin: Flink Kafka Connector

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 >

Re: Zeppelin: Flink Kafka Connector

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

Zeppelin: Flink Kafka Connector

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 f

Re: Events B33/35 in Parallel Streams Diagram

re. So B35 and B31 are two different records with identical key. > The keyBy() operation sends all records with the same key to the same subtask. > > Does that answer you question? > > Best, Fabian > > 2016-09-29 17:22 GMT+02:00 Neil Derraugh <mailto:neil.derra...@intellify

Events B33/35 in Parallel Streams Diagram

Hi, I’m confused about the meaning of event(s?) B33 and B35 in the Parallel Streams Diagram (https://ci.apache.org/projects/flink/flink-docs-master/dev/event_time.html#watermarks-in-parallel-streams