unknowntpo opened a new pull request, #23572: URL: https://github.com/apache/kafka/pull/23572
`LogCompactionTest.test_log_compaction` is flaky because `LogCompactionTester` stops at the first empty `poll()`. Since KAFKA-12980, `poll()` can return no records while data remains (after compaction, the position jumps past removed records, see KAFKA-14865), so the tester sometimes stops early and the validation fails. This change gets the end offsets before consuming and polls until the position of every partition reaches its end offset, with an overall timeout. `LogCompactionTesterTest` covers an empty poll before the end offset with `MockConsumer`. -- 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]
