public class ReadFromKafka
extends Object
Read Strings from Kafka and print them to standard out.
Note: On a cluster, DataStream.print() will print to the TaskManager's .out file!
Please pass the following arguments to run the example:
--topic test --bootstrap.servers localhost:9092 --zookeeper.connect localhost:2181 --group.id myconsumer