kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Damian Guy <damian....@gmail.com>
Subject Re: Less poll interval on StoreChangelogReader
Date Tue, 09 Jan 2018 09:00:25 GMT
State Store restoration is done on the same thread as processing. It is
actually interleaved with processing, so we keep the poll time small so
that if there is no data immediately available we can continue to process
data from other running tasks.

On Tue, 9 Jan 2018 at 08:03 Sameer Kumar <sam.kum.work@gmail.com> wrote:

> In StoreChangelogReader.restore, we have a very short poll interval of 10
> ms. Any specfic reasons for the same.
> -Sameer.

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message