Re: Consumer group rebalancing

2021-07-23 Thread Sophie Blee-Goldman
Check out the GroupCoordinator logs, they say why the group is rebalancing. Specifically the one that begins "Preparing to rebalance group" If you search for that in the logs you shared, it shows the reason: 2021-07-22 09:26:37,202 INFO [GroupCoordinator 1]: Preparing to rebalance > group shows_e

Consumer group rebalancing

2021-07-23 Thread shreyas shetty
Hi we have around 70-75 topics created on kafka cluster. And there is a consumer pod which is running in different namespace. This consumer pod creates separate consumer group for each of the topic. when I check the logs of consumer pod it shows the below error: ``` GroupId: shows_elk_Group, Top

Re: Consumer Group rebalancing events

2020-09-03 Thread Devaki, Srinivas
nd analyse them. > > On 2020/08/23 16:39:35, "Devaki, Srinivas" > wrote: > > Hi Folks, > > > > I’m trying to find the consumer group rebalancing events, so to plot how > > much time consumer groups usually take in rebalancing during application > >

Re: Consumer Group rebalancing events

2020-08-25 Thread Tess D'erberwill
. We run additional service which gets necessary metrics from this endpoint and analyse them. On 2020/08/23 16:39:35, "Devaki, Srinivas" wrote: > Hi Folks, > > I’m trying to find the consumer group rebalancing events, so to plot how > much time consumer groups usually take

Re: Consumer Group rebalancing events

2020-08-25 Thread Таисия Дорошенкова
. We run additional service which gets necessary metrics from this endpoint and analyse them. --   С уважением, Таисия Дорошенкова On 2020/08/23 16:39:35, "Devaki, Srinivas" < me@eightnoteight.space > wrote: > Hi Folks, > > I’m trying to find the consumer group rebalanci

Consumer Group rebalancing events

2020-08-23 Thread Devaki, Srinivas
Hi Folks, I’m trying to find the consumer group rebalancing events, so to plot how much time consumer groups usually take in rebalancing during application deployments. I’ve tried to check the logs of `server.log`, `controller.log`, `state-change.log`. but couldn’t find anything about