Improve Kafka consumer group stability.

Prior to this change, Kafka consumer group sometimes may need to rebalance twice after Kafka group coordinator restart.