Sorry, seems it works as you said. System.out.print("+") in my test is
buffered. It does not show the "+" immediately till I print a new line. Weird.
Thanks a lot!
Yan
-Original Message-
From: Yan Wang
Sent: Sunday, June 25, 2017 11:18 PM
To: dev@kafka.apache.or
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 pending.
-Jason
On Fri, Jun 23, 2017 at 1:43 PM, Yan Wang wrote:
> How the pause infl
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
