Re: Unable to Read from Kafka [ zookeeper.connect error]

2016-03-19 Thread subash basnet
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 presumab

Re: Unable to Read from Kafka [ zookeeper.connect error]

2016-03-19 Thread Stefano Baghino
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 wrote: > Hello all, > >

Unable to Read from Kafka [ zookeeper.connect error]

2016-03-19 Thread subash basnet
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 K

Re: Unable to Read from Kafka [ zookeeper.connect error]

2016-03-19 Thread Robert Metzger
Hi, you can set the property by passing it as an argument when starting the job: --zookeeper.connect localhost:2181 On Wed, Mar 16, 2016 at 3:17 PM, subash basnet wrote: > Hello all, > > I ran the WriteIntoKafka.java/WikipediaAnalysis.java from flink-streaming > examples and able to view the out