Hello all, I ran the WriteIntoKafka.java/WikipediaAnalysis.java from flink-streaming examples and able to view the output stream in the terminal via following command: >bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wiki-result But I am unable to read the same stream written to Kafka via ReadFromKafKa.java. I pass the following as my arguments while running ReadFromKafKa.java: --topic wiki-result --bootstrap.servers localhost:9092 --group.id myconsumer
I get the following error: Exception in thread "main" java.lang.IllegalArgumentException: *Required property 'zookeeper.connect' has not been set in the properties* at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.validateZooKeeperConfig(FlinkKafkaConsumer08.java:581) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.<init>(FlinkKafkaConsumer08.java:215) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.<init>(FlinkKafkaConsumer08.java:193) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.<init>(FlinkKafkaConsumer08.java:160) at org.apache.flink.streaming.examples.kafka.ReadFromKafka.main(ReadFromKafka.java:54) How to set property 'zookeeper.connect', or what am I doing wrong? Best Regards, Subash Basnet
