Re: Resource based kafka assignor

2020-01-31 Thread John Roesler
Hi Srinivas, Your approach sounds fine, as long as you don’t need the view of the assignment to be strictly consistent. As a roughy approximation, it could work. On the other hand, if you’re writing a custom assignor, you could consider using the SubscriptionInfo field of the joinGroup request

Re: Resource based kafka assignor

2020-01-30 Thread Devaki, Srinivas
Also, want to clarify one more doubt, is there any way for the client to explicitly trigger a rebalance without dying itself? On Thu, Jan 30, 2020 at 7:54 PM Devaki, Srinivas wrote: > Hi All, > > We have a set of logstash consumer groups running under the same set of > instances, we have decide