Re: Flink Streaming example: Kafka010Example.scala doesn't work

2017-10-20 Thread Tzu-Li (Gordon) Tai
Hi, Thanks for reporting back! That’s good to know. Gordon On 20 October 2017 at 3:51:21 PM, Wojtkowski, Michal (michal.wojtkowski@roche.com) wrote: Hi Gordon,  Thanks for finding time to write back! I managed to solve the issue and it turned out to be entirely related to kafka instance

Re: Flink Streaming example: Kafka010Example.scala doesn't work

2017-10-19 Thread Tzu-Li (Gordon) Tai
Hi Michal, I can’t seem to access the link you provided for the logs. As for confirming whether or not some data was read / written, how exactly did you test that? In the procedure you laid out, it seems like you only performed some consumer group offset checks using the Kafka CLI. AFAIK, since

Flink Streaming example: Kafka010Example.scala doesn't work

2017-10-15 Thread Wojtkowski, Michal
Hi guys I'm trying to run official "Kafka010Example.scala", but unortunatelly it doesn't read from input topic and write to output as expected. What am I missing or doing wrong? Any help or hints much appreciated. Here's exactly what I did: 1) Started kafka in docker container (spotify/kafka:late