From 408ce19c629432e987211d5cf4cf308ff945c9cc Mon Sep 17 00:00:00 2001 From: TengYao Chi Date: Sun, 15 Dec 2024 15:48:11 +0800 Subject: [PATCH] KAFKA-18245 add Flaky annotation to testMetricsDuringTopicCreateDelete (#18187) Reviewers: Chia-Ping Tsai --- .../integration/MetricsDuringTopicCreationDeletionTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala b/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala index 9e11980f607..01d96ef6318 100644 --- a/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala +++ b/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala @@ -24,7 +24,8 @@ import kafka.utils.{Logging, TestUtils} import scala.jdk.CollectionConverters._ import org.junit.jupiter.api.{BeforeEach, TestInfo} import com.yammer.metrics.core.Gauge -import org.apache.kafka.server.config.{ServerConfigs, ReplicationConfigs, ServerLogConfigs} +import org.apache.kafka.common.test.api.Flaky +import org.apache.kafka.server.config.{ReplicationConfigs, ServerConfigs, ServerLogConfigs} import org.apache.kafka.server.metrics.KafkaYammerMetrics import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ValueSource @@ -71,6 +72,7 @@ class MetricsDuringTopicCreationDeletionTest extends KafkaServerTestHarness with */ @ParameterizedTest @ValueSource(strings = Array("kraft")) + @Flaky("KAFKA-18245") def testMetricsDuringTopicCreateDelete(quorum: String): Unit = { // For UnderReplicatedPartitions, because of https://issues.apache.org/jira/browse/KAFKA-4605