[
https://issues.apache.org/jira/browse/KAFKA-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15246262#comment-15246262
]
Jason Gustafson commented on KAFKA-3529:
----------------------------------------
[~ijuma] [~guozhang] Since we call poll(0) in commitAsync() now, I think it's
possible that some of the commits are returning before the call to
awaitCommitCallback() in the test case, which is causing its expectation to
fail. Should be straightforward to fix.
> Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures
> ------------------------------------------------------------------
>
> Key: KAFKA-3529
> URL: https://issues.apache.org/jira/browse/KAFKA-3529
> Project: Kafka
> Issue Type: Sub-task
> Reporter: Ismael Juma
> Assignee: Jason Gustafson
>
> 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)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
