Hi All, I was experimenting on the new consumer API and have a question regarding the rebalance process.
I start a consumer group with single thread and make the Thread sleep while processing the records retrieved from the first consumer.poll call, i was making sure the Thread.sleep time goes beyond the session timeout and was expecting to see a rebalance on the consumer group. But when i try to get the state of the consumer group using the below command, /opt/confluent-4.0.0/bin/kafka-consumer-groups --group "consumer-grievances-group15" --bootstrap-server xxxxxxx:9092,xxxxxxxx:9092,xxxxxxxx:9092 --describe i get below result , Consumer group 'consumer-grievances-group15' has no active members. TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID TELMATEQA.grievances.grievances 0 125855 152037 26182 - - - The same happens with multiple thread in the consumer group scenario, and *going further one step i was able to make the thread get into running state, from sleep state and could see that the consumer group started off from where it left.* My only question is , why isn't the rebalancing happening in this scenario. My expectation was that the threads rebalance and start from the committed offset. Regards, Satyajit.