From c058c134d232d9eb75b00dfd900c0662d99b2de7 Mon Sep 17 00:00:00 2001 From: Alieh Saeedi <107070585+aliehsaeedii@users.noreply.github.com> Date: Fri, 11 Jul 2025 15:48:24 +0200 Subject: [PATCH] KAFKA-19496: Deflake streams admin api describe test (#20154) This fixes the flaky `DescribeStreamsGroupTest.testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions()`, which sometimes fails due to `ERROR stream-thread Missing source topics: Source topics customInputTopic2 are missing` Reviewers: Bill Bejeck --- .../apache/kafka/tools/streams/DescribeStreamsGroupTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java b/tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java index 05bf36cbc34..92c2f036f77 100644 --- a/tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java +++ b/tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java @@ -206,6 +206,7 @@ public class DescribeStreamsGroupTest { @Test public void testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions() throws Exception { + cluster.createTopic(INPUT_TOPIC_2, 1, 1); KafkaStreams streams2 = new KafkaStreams(topology(INPUT_TOPIC_2, OUTPUT_TOPIC_2), streamsProp(APP_ID_2)); startApplicationAndWaitUntilRunning(streams2); @@ -214,8 +215,8 @@ public class DescribeStreamsGroupTest { List.of(APP_ID, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "0:[0,1];", "TARGET-ACTIVE:", "0:[0,1];"), List.of(APP_ID, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "1:[0,1];", "TARGET-ACTIVE:", "1:[0,1];")); final Set> expectedRows2 = Set.of( - List.of(APP_ID_2, "2", "0", "dont-care", "streams", "2", "", ""), - List.of(APP_ID_2, "2", "0", "", "streams", "2", "", "")); + List.of(APP_ID_2, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "1:[0];", "TARGET-ACTIVE:", "1:[0];"), + List.of(APP_ID_2, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "0:[0];", "TARGET-ACTIVE:", "0:[0];")); final Map>> expectedRowsMap = new HashMap<>(); expectedRowsMap.put(APP_ID, expectedRows1); expectedRowsMap.put(APP_ID_2, expectedRows2);