C0urante opened a new pull request, #16771: URL: https://github.com/apache/kafka/pull/16771
We've been seeing some flaky test failures since we modified the consumer group warmup logic with the exception `java.lang.IllegalStateException: You can only check the position for partitions assigned to this consumer.` These are caused because, even after `Consumer::poll` has returned, it's possible that the consumer has not yet joined the group or been assigned topic partitions. To address this, some retry logic is added during consumer warmup to ensure (for real this time!) that the consumer has joined the group and fetched offsets for every applicable topic partition before committing offsets. ### 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
