You found one of my comments ;) Regards JB
On 03/18/2016 06:38 PM, Raghu Angadi wrote:
On Fri, Mar 18, 2016 at 9:55 AM, Raghu Angadi <[email protected] <mailto:[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.
-- Jean-Baptiste Onofré [email protected] http://blog.nanthrax.net Talend - http://www.talend.com
