current assumption appears to be that a call to poll() indicates that
there are no more in-flight messages. Attempting to decouple consumer and
processor threads or the streaming of multiple batches results in
unavoidable redeliveries during a rebalance.
Regards
Simon Souter
https://github.com
rrent interface and in some cases we cant totally avoid
redeliveries when rebalancing.
Regards,
*Simon* *Souter*
https://github.com/cakesolutions/scala-kafka-client
On 19 July 2016 at 02:22, Jason Gustafson wrote:
> Hey Simon,
>
> Sorry for the late response. The onPartitionsRevoked()
gt; Even if we change the connections.max.idle.ms to work including
> > the
> > > > > > connecting phrase, we can not set this parameter to a small
> value,
> > > such
> > > > > as
> > > > > > 5 seconds. Because the client is ma
