[
https://issues.apache.org/jira/browse/KAFKA-9399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9399.
----------------------------------
Resolution: Fixed
> Flaky Test
> BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild
> -------------------------------------------------------------------------------
>
> Key: KAFKA-9399
> URL: https://issues.apache.org/jira/browse/KAFKA-9399
> Project: Kafka
> Issue Type: Bug
> Components: streams, unit tests
> Affects Versions: 2.5.0
> Reporter: Matthias J. Sax
> Priority: Critical
> Labels: flaky-test
>
> [https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/172/testReport/junit/org.apache.kafka.streams.integration/BranchedMultiLevelRepartitionConnectedTopologyTest/testTopologyBuild/]
> {quote}java.lang.AssertionError: Condition not met within timeout 15000.
> Failed to observe stream transits to RUNNING at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26) at
> org.apache.kafka.test.TestUtils.lambda$waitForCondition$4(TestUtils.java:369)
> at
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:417)
> at
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:385)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:368) at
> org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:339) at
> org.apache.kafka.streams.integration.BranchedMultiLevelRepartitionConnectedTopologyTest.testTopologyBuild(BranchedMultiLevelRepartitionConnectedTopologyTest.java:146){quote}
> STDOUT
> {quote}[2020-01-10 20:54:59,190] WARN [Consumer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-consumer,
> groupId=branched-repartition-topic-test] Connection to node 0
> (localhost/127.0.0.1:38720) could not be established. Broker may not be
> available. (org.apache.kafka.clients.NetworkClient:756) [2020-01-10
> 20:54:59,264] WARN [Producer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-producer]
> Connection to node 0 (localhost/127.0.0.1:38720) could not be established.
> Broker may not be available. (org.apache.kafka.clients.NetworkClient:756)
> [2020-01-10 20:54:59,314] WARN [AdminClient
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-admin]
> Connection to node 0 (localhost/127.0.0.1:38720) could not be established.
> Broker may not be available. (org.apache.kafka.clients.NetworkClient:756)
> ...
> [2020-01-10 20:54:59,356] WARN [Consumer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-restore-consumer,
> groupId=null] Connection to node -1 (localhost/127.0.0.1:38720) could not be
> established. Broker may not be available.
> (org.apache.kafka.clients.NetworkClient:756) [2020-01-10 20:54:59,356] WARN
> [Consumer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-restore-consumer,
> groupId=null] Bootstrap broker localhost:38720 (id: -1 rack: null)
> disconnected (org.apache.kafka.clients.NetworkClient:1024) [2020-01-10
> 20:54:59,391] WARN [Consumer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-consumer,
> groupId=branched-repartition-topic-test] Connection to node 0
> (localhost/127.0.0.1:38720) could not be established. Broker may not be
> available. (org.apache.kafka.clients.NetworkClient:756) [2020-01-10
> 20:54:59,457] WARN [Consumer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-restore-consumer,
> groupId=null] Connection to node -1 (localhost/127.0.0.1:38720) could not be
> established. Broker may not be available.
> (org.apache.kafka.clients.NetworkClient:756) [2020-01-10 20:54:59,457] WARN
> [Consumer
> clientId=branched-repartition-topic-test-7bb4acef-c1c1-401f-adb9-a67a448cae02-StreamThread-1-restore-consumer,
> groupId=null] Bootstrap broker localhost:38720 (id: -1 rack: null)
> disconnected (org.apache.kafka.clients.NetworkClient:1024)
> ...
> and some more of those...{quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
