[ https://issues.apache.org/jira/browse/KAFKA-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984973#comment-15984973 ]
ASF GitHub Bot commented on KAFKA-5124: --------------------------------------- GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2921 KAFKA-5124: autocommit reset earliest fixes race condition Fixes `org.apache.kafka.streams.integration.utils.IntegrationTestUtils#readKeyValues` potentially starting to `poll` for stream output after the stream finished sending the test data and hence missing it when working with `latest` offsets. You can merge this pull request into a Git repository by running: $ git pull https://github.com/original-brownbear/kafka KAFKA-5124 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2921.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2921 ---- commit bdd06b97c57ec06714f1f654d5b2f2621143224f Author: Armin Braun <m...@obrown.io> Date: 2017-04-26T15:10:44Z KAFKA-5124: autocommit reset earliest fixes race condition ---- > shouldInnerLeftJoin unit test fails > ----------------------------------- > > Key: KAFKA-5124 > URL: https://issues.apache.org/jira/browse/KAFKA-5124 > Project: Kafka > Issue Type: Sub-task > Components: streams > Affects Versions: 0.10.2.0 > Reporter: Eno Thereska > Assignee: Armin Braun > Fix For: 0.11.0.0 > > > Unit test on trunk gives occasional failure: > org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest > > shouldInnerLeftJoin FAILED > java.lang.AssertionError: Condition not met within timeout 30000. > Expecting 1 records from topic output- while only received 0: [] > at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:265) > at > org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:207) > at > org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinKeyValueRecordsReceived(IntegrationTestUtils.java:176) > at > org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest.verifyKTableKTableJoin(KTableKTableJoinIntegrationTest.java:222) > at > org.apache.kafka.streams.integration.KTableKTableJoinIntegrationTest.shouldInnerLeftJoin(KTableKTableJoinIntegrationTest.java:143) -- This message was sent by Atlassian JIRA (v6.3.15#6346)