Class | Description |
---|---|
ReadFromKafka |
Read Strings from Kafka and print them to standard out.
|
WriteIntoKafka |
Generate a String every 500 ms and write it into a Kafka topic
Please pass the following arguments to run the example:
--topic test --bootstrap.servers localhost:9092
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.