It seems like there generally has been the assumption that the broker needs to know about this delay either from its own config or provided over the wire from clients. Is this actually true?
One alternative I don't think was mentioned was to make this delay concept be completely client-side. What I mean by this is maybe we can just locally postpone on the client any message consumption or callback trigger from happening for the first N seconds after rebalance. The client in the meantime can heartbeat and get notified of rebalances during this delay. I haven't really thought it through in detail. Please let me know if I'm missing something. On Thu, Mar 30, 2017 at 6:03 PM, Dong Lin <[email protected]> wrote: > +1 (non-binding) > > Thanks! > > > On Thu, Mar 30, 2017 at 6:03 PM, Becket Qin <[email protected]> wrote: > > > +1 Thanks for the KIP! > > > > On Thu, Mar 30, 2017 at 12:55 PM, Jason Gustafson <[email protected]> > > wrote: > > > > > +1 Thanks for the KIP! > > > > > > On Thu, Mar 30, 2017 at 12:51 PM, Guozhang Wang <[email protected]> > > > wrote: > > > > > > > +1 > > > > > > > > Sorry about the previous email, Gmail seems be collapsing them into a > > > > single thread on my inbox. > > > > > > > > Guozhang > > > > > > > > On Thu, Mar 30, 2017 at 11:34 AM, Guozhang Wang <[email protected]> > > > > wrote: > > > > > > > > > Damian, could you create a new thread for the voting process? > > > > > > > > > > Thanks! > > > > > > > > > > Guozhang > > > > > > > > > > On Thu, Mar 30, 2017 at 10:33 AM, Bill Bejeck <[email protected]> > > > wrote: > > > > > > > > > >> +1(non-binding) > > > > >> > > > > >> On Thu, Mar 30, 2017 at 1:30 PM, Eno Thereska < > > [email protected] > > > > > > > > >> wrote: > > > > >> > > > > >> > +1 (non binding) > > > > >> > > > > > >> > Thanks > > > > >> > Eno > > > > >> > > On 30 Mar 2017, at 18:01, Matthias J. Sax < > > [email protected]> > > > > >> wrote: > > > > >> > > > > > > >> > > +1 > > > > >> > > > > > > >> > > On 3/30/17 3:46 AM, Damian Guy wrote: > > > > >> > >> Hi All, > > > > >> > >> > > > > >> > >> I'd like to start the voting thread on KIP-134: > > > > >> > >> https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > > > >> > 134%3A+Delay+initial+consumer+group+rebalance > > > > >> > >> > > > > >> > >> Thanks, > > > > >> > >> Damian > > > > >> > >> > > > > >> > > > > > > >> > > > > > >> > > > > > >> > > > > > > > > > > > > > > > > > > > > -- > > > > > -- Guozhang > > > > > > > > > > > > > > > > > > > > > -- > > > > -- Guozhang > > > > > > > > > >
