Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
I've seen a few failures of kafka.api.PlaintextConsumerTest.testAsyncCommit recently.
I wonder if it's related to: https://github.com/apache/kafka/commit/8d8e3aaa6172d314230a8d61e6892e9c09dc45b6
hachikuji, thoughts?
Stacktrace looks like:
java.lang.AssertionError: expected:<6> but was:<5>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at org.junit.Assert.assertEquals(Assert.java:631)
at kafka.api.BaseConsumerTest.awaitCommitCallback(BaseConsumerTest.scala:340)
at kafka.api.PlaintextConsumerTest.testAsyncCommit(PlaintextConsumerTest.scala:246)