public class Kafka010Example extends Object
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 (message,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 |
---|
Kafka010Example() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.