ShivsundarR opened a new pull request, #21206: URL: https://github.com/apache/kafka/pull/21206
*What* Currently, when `ShareConsumerImpl::poll()` times out with an empty response, the background thread does not automatically stop fetching from the broker. The `ShareConsumeRequestManager` keeps sending requests until it actually receives any data. This means we could continue fetching from the broker when we did not intend to and these records would unnecessarily start timing out sooner than we want. This was noticed during a integ test which was previously flaky when it had an extra `poll()` before we started producing data. PR fixes this by passing the `pollTimeout` through the `ShareFetchEvent` sending fetch requests as soon as the user passed timeout completes on the application. -- 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]
