Hi All,
We have two consumers in a consumer group subscribed to the topic.
Both the consumers are in different servers. The topic consists of 11
partitions and 1 replication. Normally, 5 partitions are consumed in
consumer 1 and remaining in consumer 2. Whenever there is a connection
glitch between consumers and the coordinator, the rebalance procedure is
running on both consumers. During this procedure, all the 11 partitions are
assigned to consumer1 and two of the partitions (which are assigned to
consumer1) are assigned to consumer2. This leads to lockexception in
consumer2 and consumer2 remains in livelock to create state directories for
those two partitons.
Kafka version: 0.11.0.0
Zookeeper: 3.4.10
