Hello Stefano, Thank you, it's working :). Regards, Subash Basnet
On Wed, Mar 16, 2016 at 3:24 PM, Stefano Baghino < stefano.bagh...@radicalbit.io> wrote: > Hi Subash, > > you just have to add the following parameter: --zookeeper.connect > localhost:2181 > Let us know if it works before presumably the usage string for the > ReadFromKafka example can by incorrect. > > Hope I've been helpful. > > On Wed, Mar 16, 2016 at 3:17 PM, subash basnet <yasub...@gmail.com> wrote: > >> 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 >> > > > > -- > BR, > Stefano Baghino > > Software Engineer @ Radicalbit >
