Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-02-02 Thread Navneet Kumar
Appreciate you efforts On 2 Feb 2018 2:37 p.m., "Zoran" wrote: > I just want to say that I have solved the situation by deleting > zookeeper's and kafka's data directories and setting > offsets.topic.replication.factor=3 in kafka server.properties file. > > After that, __consumer_offsets topic i

Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-02-02 Thread Zoran
I just want to say that I have solved the situation by deleting zookeeper's and kafka's data directories and setting offsets.topic.replication.factor=3 in kafka server.properties file. After that, __consumer_offsets topic is replicated and everything works as expected. I hope this will help

Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-01-31 Thread Dmitry Minkovsky
This is not my question, but I saw it on Stack Overflow yesterday and have been wondering about it: https://stackoverflow.com/questions/48523972/group- consumer-cannot-consume-messages-if-kafka-service-on-specific-node-in-test. Anyone else seen behavior like this?

Re: Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-01-30 Thread Zoran
Sorry, I have attached wrong server.properties file. Now the right one is in the attachment. Regards. On 01/30/2018 02:59 PM, Zoran wrote: Hi, I have three servers: blade1 (192.168.112.31), blade2 (192.168.112.32) and blade3 (192.168.112.33). On each of servers kafka_2.11-1.0.0 is installe

Group consumer cannot consume messages if kafka service on specific node in test cluster is down

2018-01-30 Thread Zoran
Hi, I have three servers: blade1 (192.168.112.31), blade2 (192.168.112.32) and blade3 (192.168.112.33). On each of servers kafka_2.11-1.0.0 is installed. On blade3 (192.168.112.33:2181) zookeeper is installed as well. I have created a topic repl3part5 with the following line: bin/kafka-topics