Also, great job on the KIP, Jason. I love the solution you found and I love how well you explained it in the KIP.
On Wed, Jan 13, 2016 at 8:38 PM, Gwen Shapira <g...@confluent.io> wrote: > +1 (binding) > > On Wed, Jan 13, 2016 at 6:18 PM, Jason Gustafson <ja...@confluent.io> > wrote: > >> Hi All, >> >> I'd like to open up the vote on KIP-41. This KIP adds a new consumer >> configuration option "max.poll.records" which sets an upper bound on the >> number of records returned in a call to poll(). This gives users a way to >> limit message processing time to avoid unexpected rebalancing. This change >> is backwards compatible with the default implementing the current >> behavior. >> >> Here's a link to the KIP wiki: >> >> https://cwiki.apache.org/confluence/display/KAFKA/KIP-41%3A+KafkaConsumer+Max+Records >> >> Thanks, >> Jason >> > >
