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
