Re: Need feedbacks to consumer if hangs due to some __consumer_offsets partitions failed

2018-01-10 Thread Xin Li
Hey, I think you can do it in two ways: 1. Manually increase the replication factor 2. In the server.config file, change the default.replication.factor Best, Xin On 09.01.18, 07:46, "1095193...@qq.com" <1095193...@qq.com> wrote: hi My kafka cluster has two brokers( 0 and 1) and i

Need feedbacks to consumer if hangs due to some __consumer_offsets partitions failed

2018-01-08 Thread 1095193...@qq.com
hi My kafka cluster has two brokers( 0 and 1) and it created __consumer_offsets topic has 50 partitions . When broker 0 failed, half of partitions failed (because topic __consumer_offsets ReplicationFactor is 1). This results consequence that my kafkaConsumer sometimes can work w