I've resolved this issue. In the end, it was caused by heartbeat expiration. My polling is correct, however, it seems to be suffering from thread starvation. I'm not sure what the fix is in general for that. Fortunately, increasing session.timeout.ms was enough for my situation.
Thanks --Scott On Fri, Apr 6, 2018 at 8:53 AM, Gabriel Giussi <gabrielgiu...@gmail.com> wrote: > Ok, the other thing that come to my mind is to check the > max.poll.interval.ms configuration. You said that "poll is invoked > regularly" but this isn't very specific. > The default value for max.poll.interval.ms is 5 minutes (300000 millis) so > if you are executing a poll regularly each 6 minutes, you will see > rebalacing. > > > 2018-04-05 19:01 GMT-03:00 Scott Thibault <scott.thiba...@multiscalehn.com > >: > > > No, there is only one consumer in the group. > > > > > > On Thu, Apr 5, 2018 at 2:39 PM, Gabriel Giussi <gabrielgiu...@gmail.com> > > wrote: > > > > > There is some other consumer (in the same process or another) using the > > > same group.id? > > > > > > 2018-04-05 14:36 GMT-03:00 Scott Thibault <scott.thibault@multiscalehn. > > com > > > >: > > > > > > > I'm using the Kafka 1.0.1 Java client with 1 consumer and 1 partition > > and > > > > using the ConsumerRebalanceListener I can see that the partition > keeps > > > > getting revoked and then reassigned. My consumer is in it's own > thread > > > to > > > > ensure poll is invoked regularly. Is there some other reason this > > might > > > be > > > > happening? > > > > > > > > > >
