diff --git a/build.gradle b/build.gradle index 7abd1b7c60078..fa11d814a7fe3 100644 --- a/build.gradle +++ b/build.gradle @@ -2534,6 +2534,7 @@ project(':tools') { testImplementation project(':core').sourceSets.test.output testImplementation project(':test-common:test-common-internal-api') testImplementation project(':test-common:test-common-runtime') + testImplementation project(':test-common:test-common-util') testImplementation project(':server-common') testImplementation project(':server-common').sourceSets.test.output testImplementation project(':connect:api') 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 354118397ac9f..34a472a137cf2 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 @@ -20,6 +20,7 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.common.errors.TimeoutException; import org.apache.kafka.common.serialization.Serdes; +import org.apache.kafka.common.test.api.Flaky; import org.apache.kafka.common.utils.Exit; import org.apache.kafka.streams.GroupProtocol; import org.apache.kafka.streams.KafkaStreams; @@ -259,6 +260,7 @@ public void testDescribeNonExistingStreamsGroup() { List.of("--bootstrap-server", bootstrapServers, "--describe", "--verbose", "--members", "--group", nonExistingGroup), errorMessage); } + @Flaky("KAFKA-19701") @Test public void testDescribeStreamsGroupWithShortTimeout() { // Note: 1ms timeout may not always trigger timeout on fast machines with warm groups