On Fri, Mar 18, 2016 at 9:55 AM, Raghu Angadi <[email protected]> wrote:
> We have fairly well tested patch for KafkaIO (pr #121 > <https://github.com/GoogleCloudPlatform/DataflowJavaSDK/pull/121>). It > will be merged soon. The example there keeps track of top hashtags in 10 > minute sliding window and writes the results to another Kafka topic. Please > try it if you can. It is well tested on Google Cloud Dataflow. I have not > run it using Flink runner. > btw, KafkaIO above does not implement a Sink. The example app publishes the results directly to Kafka.
