Re: (auto.commit.interval = heartbeat.interval) => infinite rebalance loop

2016-04-04 Thread Caesar Ralf Franz Hoppen
m over and over. Here > is a link to a JIRA where we're trying to address the underlying problem: > https://issues.apache.org/jira/browse/KAFKA-3488. > > -Jason > > On Thu, Mar 31, 2016 at 1:16 AM, Caesar Ralf Franz Hoppen < > caesar.r...@gmail.com> wrote: > &g

(auto.commit.interval = heartbeat.interval) => infinite rebalance loop

2016-03-31 Thread Caesar Ralf Franz Hoppen
Hej, So there seems to be a weird problem that happens if you happen to setup your heartbeat.interval.ms equal to your autocommit.interval.ms. >From what I see in the logs, it never successfully send a heartbeat when there was a commit before, so the consumer expires after the

Re: consumer group, why commit requests are not considered as effective heartbeats?

2016-03-30 Thread Caesar Ralf Franz Hoppen
I would like to add a little more to this context, the problem is not hard to reproduce. If you are using - auto commit - heartbeat time = commit time - more than one consumer It seems that is always failing to send the heart beat. Changing the values for the heartbeat and commit to be