I see... doesn't that cause flapping though? On Wed, Jan 4, 2017 at 8:22 PM, Ewen Cheslack-Postava <e...@confluent.io> wrote:
> 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 > > >
