Re: Fault tolerance not working in Kafka

2017-02-05 Thread Stevo Slavić
Check __consumer-offsets topic, number of partitions and their replica assignment. You may be affected by problem solved by https://cwiki.apache.org/confluence/display/KAFKA/KIP-115%3A+Enforce+offsets.topic.replication.factor+upon+__consumer_offsets+auto+topic+creation On Mon, Feb 6, 2017, 06:32 R

Re: Fault tolerance not working in Kafka

2017-02-05 Thread R Krishna
What is the exact exception you see? With 4 partitions, consumers should not have a problem if one goes down, do you see any broker ISR for your topic? On Sun, Feb 5, 2017 at 8:15 PM, Nitin Shende wrote: > Hi Team, > > I am using Apache kafka with 6 brokers. I m having topic with 4 partition > a

Fault tolerance not working in Kafka

2017-02-05 Thread Nitin Shende
Hi Team, I am using Apache kafka with 6 brokers. I m having topic with 4 partition and replication factor 3, my java code is able to consume messages when all brokers are up. But when I one broker is killed then java consumer stops working. Could you please help? Best Regards, Nitin Shende, +91 9