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 well and
sometimes hangs with 0 outputs. My consumer generated a new goupid upon it
start up . When consumer startup, it will request groupcoordinator with groupid
. When Consumer's groupid is routed to a good partition, it can work well,
when grouid is routed to a failed partition, it hangs with a response
GROUP_COORDINATOR_NOT_AVAILABLE. I hope broker can feedback to consumer if
hangs due to some __consumer_offsets partitions failed , it can help user
improve expericence and debug issure fastly.
[email protected]
