public class Kafka011Example extends Object
KafkaEvent
, group by some key, and finally
perform a rolling addition on each key for which the results are written back to another topic.
This example also demonstrates using a watermark assigner to generate per-partition watermarks directly in the Flink Kafka consumer. For demonstration purposes, it is assumed that the String messages are of formatted as a (word,frequency,timestamp) tuple.
Example usage: --input-topic test-input --output-topic test-output --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --group.id myconsumer
Constructor and Description |
---|
Kafka011Example() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.