The coordinator will immediately move the group into a rebalance if it needs it. The reason LeaveGroupRequest was added was to avoid having to wait for the session timeout before completing a rebalance. So aside from the latency of cleanup/committing offests/rejoining after a heartbeat, rolling bounces should be fast for consumer groups.
-Ewen On Wed, Jan 4, 2017 at 5:19 PM, Pradeep Gollakota <pradeep...@gmail.com> wrote: > Hi Kafka folks! > > When a consumer is closed, it will issue a LeaveGroupRequest. Does anyone > know how long the coordinator waits before reassigning the partitions that > were assigned to the leaving consumer to a new consumer? I ask because I'm > trying to understand the behavior of consumers if you're doing a rolling > restart. > > Thanks! > Pradeep >
