Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
Description
java.lang.AssertionError: Consumed 6 records until timeout instead of the expected 8 records at kafka.utils.TestUtils$.fail(TestUtils.scala:333) at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:847) at kafka.utils.TestUtils$.consumeRecords(TestUtils.scala:1357) at kafka.api.TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData(TransactionsTest.scala:143)