-
Type:
Sub-task
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 0.10.0.0
-
Component/s: None
-
Labels:None
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
Jason Gustafson, 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)