Hi,
 the polls method works with an internal buffer, on a timeout it will
return records in the internal buffers, not necessary from the
topic/partition in the broker.

Missatge de Mark Anderson <manderso...@gmail.com> del dia dl., 4 de febr.
2019 a les 19:57:

> I'm sure I initially made this assumption when trying to read all records
> from a compacted topic on application startup and it was incorrect.
>
> Due to latency, threading GC pauses etc it would return 0 when there were
> still records on the topic.
>
> Mark
>
> On Mon, 4 Feb 2019, 18:02 Pere Urbón Bayes <pere.ur...@gmail.com wrote:
>
> > Hi,
> >   see from the javadocs:
> >
> > > timeout - The time, in milliseconds, spent waiting in poll if data is
> not
> > available in the buffer. If 0, returns immediately with any records that
> > are available currently in the buffer, else returns empty. Must not be
> > negative.
> >
> > for a network problem it will return an exception.
> >
> > I hope it helps,
> >
> > -- Pere
> >
> >
> >
> > Missatge de Mark Horton <m...@nostromo.net> del dia dl., 4 de febr.
> 2019 a
> > les 18:27:
> >
> > > This is a theoretical question. I have not seen this behavior but
> > > wanted to know if it was possible.
> > >
> > > If consumer.poll() returns EMPTY, does that always mean no records are
> > > currently available? In other words, let's say there are some records
> > > in a partition. Could poll() return EMPTY if there was a network
> > > problem that caused it to timeout before it could return that record?
> > >
> > > Mark
> > >
> >
> >
> > --
> > Pere Urbon-Bayes
> > Software Architect
> > http://www.purbon.com
> > https://twitter.com/purbon
> > https://www.linkedin.com/in/purbon/
> >
>


-- 
Pere Urbon-Bayes
Software Architect
http://www.purbon.com
https://twitter.com/purbon
https://www.linkedin.com/in/purbon/

Reply via email to