I have seen the zk consumers directory getting corrupted due to running
your consumer again and again with some settings changed and causing this
issue. I will do a removal of zk directory from kafka server's zk like below
rmr /consumers/hello and exit zookeeper shell.
Then run your consumer and
Yes, try this command replacing the bracketed things with the correct
identification for your project:
*bin/kafka-console-consumer.sh --zookeeper [zookeeper info] --topic
[your-topic-here] --from-beginning*
On Mon, Jun 29, 2015 at 9:56 AM, shivam tiwari wrote:
> It turns out to be the code ment
It turns out to be the code mentioned does not read topic from beginning
and actually waits for producer to produce something fresh. After starting
producer and sending messages I was able to retrieve all the messages. Is
there a way to get messages on topic from beginning?
On 26 June 2015 at 14:3
Zookeeper actually doesn't show any errors - it shows a warning, which
is pretty normal.
What does your consumer and Kafka broker show? Are there any errors in
the consumer? Or is it just hanging?
You may want to consult our FAQ:
https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whydoesmy
Kafka 0.8.2.2.3 and zookeper both are running inside VM. I was able to run
both producer and consumer within VM successfully using
kafka-console-producer.sh and kafka-console-consumer.sh respectively. Even
I was able to consume Kafka messages from host machine using
kafka-console-consumer.sh. But w
Kafka 0.8.2.2.3 and zookeper both are running inside VM. I was able to run
both producer and consumer within VM successfully using
kafka-console-producer.sh and kafka-console-consumer.sh respectively. Even
I was able to consume Kafka messages from host machine using
kafka-console-consumer.sh. But w
