I'm following the approach of the AdvancedConsumer example, which is to pause the partition and continue to invoke poll (several times a second) while the actual processing is done on another thread.
--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? > > > > > > > > > >
