ll).
Is it a bug or right behavior?
Thanks a lot!
Yan
-Original Message-
From: Jason Gustafson [mailto:ja...@confluent.io]
Sent: Friday, June 23, 2017 3:08 PM
To: dev@kafka.apache.org
Subject: Re: Pause and max.poll.records
Fetches for each partition are sent once all the pending data for
?
Thanks a lot!
Yan
-Original Message-
From: Jason Gustafson [mailto:ja...@confluent.io]
Sent: Friday, June 23, 2017 3:08 PM
To: dev@kafka.apache.org
Subject: Re: Pause and max.poll.records
Fetches for each partition are sent once all the pending data for that
partition has been consumed. The
Fetches for each partition are sent once all the pending data for that
partition has been consumed. The only difference that pause makes is that
we do not bother fetching paused partitions. So in your example, p2 would
be fetched even if p1 is paused and has fetched records > max.poll.records
pendi
How the pause influences max.poll.records? If I have two partitions, say p1 and
p2. p1 has number local fetched records > max.poll.records. p2 has no data in
local but in the server (not fetched yet). Now, if I pause P1. Does the next
poll send fetch request to the server so that I can get data
