> This leads to lockexception in
>> consumer2 and consumer2 remains in livelock to create state directories for
>> those two partitons.
There is a fix for a `LockException` during rebalance in 0.11.0.1:
https://issues.apache.org/jira/browse/KAFKA-5167
Maybe upgrading helps? Note, that you can upg
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
glit
