This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 408ce19c629 KAFKA-18245 add Flaky annotation to 
testMetricsDuringTopicCreateDelete (#18187)
408ce19c629 is described below

commit 408ce19c629432e987211d5cf4cf308ff945c9cc
Author: TengYao Chi <[email protected]>
AuthorDate: Sun Dec 15 15:48:11 2024 +0800

    KAFKA-18245 add Flaky annotation to testMetricsDuringTopicCreateDelete 
(#18187)
    
    Reviewers: Chia-Ping Tsai <[email protected]>
---
 .../kafka/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

Reply via email to