mjsax opened a new pull request, #22790: URL: https://github.com/apache/kafka/pull/22790
readRecords() polls up to `waitTime` by counting a fixed 100ms per iteration rather than measuring the wall clock. A single consumer.poll() can block longer than the requested 100ms interval, and thus readReacord() can exceed the specified `waitTimeMs` by orders of magnitude. This PR bounds the loop on real elapsed time using a fixed deadline. -- 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]
