[KAFKA-15798] Flaky Test NamedTopologyIntegrationTest.shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology()

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: streams, unit tests
• Labels: flaky-test
• Assignee: Lucas Brutschy
• Reporter: Justine Olshan
• Created: 07/Nov/23 21:58
• Updated: 26/Feb/24 21:32
• Resolved: 27/Nov/23 08:35

Description

I saw a few examples recently. 2 have the same error, but the third is different

https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-14629/22/testReport/junit/org.apache.kafka.streams.integration/NamedTopologyIntegrationTest/Build___JDK_8_and_Scala_2_12___shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology___2/

https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/2365/testReport/junit/org.apache.kafka.streams.integration/NamedTopologyIntegrationTest/Build___JDK_21_and_Scala_2_13___shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology__/ 

The failure is like

java.lang.AssertionError: Did not receive all 5 records from topic output-stream-1 within 60000 ms, currently accumulated data is [] Expected: is a value equal to or greater than <5> but: <0> was less than <5>

The other failure was
https://ci-builds.apache.org/job/Kafka/job/kafka/job/trunk/2365/testReport/junit/org.apache.kafka.streams.integration/NamedTopologyIntegrationTest/Build___JDK_8_and_Scala_2_12___shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology__/

java.lang.AssertionError: Expected: <[0, 1]> but: was <[0]>