AndrewJSchofield opened a new pull request, #14789: URL: https://github.com/apache/kafka/pull/14789
When returning fetched records, the code was not properly honouring `max.poll.records`. When it had fetched records for multiple topic-partitions, it was intended to accumulate records up to `max.poll.records`. Actually, whenever it accumulated records from a partition, it was prepared to add `max.poll.records` for that partition regardless of how many records it had already accumulated, rather than reducing the number of records to add based on records already added from other partitions. I added a test case which failed before the code change in the PR and passes afterwards. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
