[
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 <[email protected]>
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)
