kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pradeep Gollakota <pradeep...@gmail.com>
Subject Re: Consumer Rebalancing Question
Date Thu, 05 Jan 2017 23:01:57 GMT
I see... doesn't that cause flapping though?

On Wed, Jan 4, 2017 at 8:22 PM, Ewen Cheslack-Postava <ewen@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 <pradeepg26@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
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message