Skip to content

Commit c058c13

Browse files
authored
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 <[email protected]>
1 parent 2346c0e commit c058c13

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -206,6 +206,7 @@ public void testDescribeStreamsGroupWithMembersAndVerboseOptions() throws Except
206206

207207
@Test
208208
public void testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions() throws Exception {
209+
cluster.createTopic(INPUT_TOPIC_2, 1, 1);
209210
KafkaStreams streams2 = new KafkaStreams(topology(INPUT_TOPIC_2, OUTPUT_TOPIC_2), streamsProp(APP_ID_2));
210211
startApplicationAndWaitUntilRunning(streams2);
211212

@@ -214,8 +215,8 @@ public void testDescribeMultipleStreamsGroupWithMembersAndVerboseOptions() throw
214215
List.of(APP_ID, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "0:[0,1];", "TARGET-ACTIVE:", "0:[0,1];"),
215216
List.of(APP_ID, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "1:[0,1];", "TARGET-ACTIVE:", "1:[0,1];"));
216217
final Set<List<String>> expectedRows2 = Set.of(
217-
List.of(APP_ID_2, "2", "0", "dont-care", "streams", "2", "", ""),
218-
List.of(APP_ID_2, "2", "0", "", "streams", "2", "", ""));
218+
List.of(APP_ID_2, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "1:[0];", "TARGET-ACTIVE:", "1:[0];"),
219+
List.of(APP_ID_2, "3", "0", "", "streams", "3", "", "", "ACTIVE:", "0:[0];", "TARGET-ACTIVE:", "0:[0];"));
219220
final Map<String, Set<List<String>>> expectedRowsMap = new HashMap<>();
220221
expectedRowsMap.put(APP_ID, expectedRows1);
221222
expectedRowsMap.put(APP_ID_2, expectedRows2);

0 commit comments

Comments
 (0)