[PR] KAFKA-20786: Bound IntegrationTestUtils.readRecords on real elapsed time [kafka]

["mjsax (via GitHub)" <gi...@apache.org>]

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: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] KAFKA-20786: Bound IntegrationTestUtils.readRecords on real elapsed time [kafka]

["lianetm (via GitHub)" <gi...@apache.org>]

lianetm merged PR #22790:
URL: https://github.com/apache/kafka/pull/22790


-- 
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-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org