RE: Pause and max.poll.records

2017-06-25 Thread Yan Wang
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

RE: Pause and max.poll.records

2017-06-25 Thread Yan Wang
? 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

Re: Pause and max.poll.records

2017-06-23 Thread Jason Gustafson
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