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 --group.id myconsumer
Constructor and Description |
---|
Kafka011Example() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.