AndrewJSchofield opened a new pull request, #21757: URL: https://github.com/apache/kafka/pull/21757
When a share consumer is initially joining a group but not yet fetching records, the poll loop has no records to wait for. Each iteration of the loop was creating an instance of `SharePollEvent` without considering whether an in-flight event existed. As a result, many events could briefly queue up for no good reason, only to be drained once the consumer successfully joined the group. The PR follows a similar design as used in the `AsyncKafkaConsumer` for managing its poll event, without that code's extra complication of validating the position. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
