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

schofielaj 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 47f22faac35 MINOR: Added flaky references for a few tests. (#18558)
47f22faac35 is described below

commit 47f22faac350f55b5263be038395c578b59ea6c7
Author: Sushant Mahajan <smaha...@confluent.io>
AuthorDate: Thu Jan 16 00:54:52 2025 +0530

    MINOR: Added flaky references for a few tests. (#18558)
    
    Reviewers: Andrew Schofield <aschofi...@confluent.io>
---
 .../test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java  | 1 +
 .../kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java  | 2 ++
 core/src/test/scala/integration/kafka/api/UserQuotaTest.scala           | 2 ++
 3 files changed, 5 insertions(+)

diff --git 
a/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
 
b/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
index 0af2aa0f096..6e521c65898 100644
--- 
a/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
+++ 
b/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
@@ -1782,6 +1782,7 @@ public class KafkaAdminClientTest {
         }
     }
 
+    // @Flaky("KAFKA-18441")
     @Test
     public void testAdminClientApisAuthenticationFailure() {
         Cluster cluster = mockBootstrapCluster();
diff --git 
a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java
 
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java
index d005318cb8d..a4b8e457f37 100644
--- 
a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java
+++ 
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/EagerConsumerCoordinatorTest.java
@@ -22,4 +22,6 @@ public class EagerConsumerCoordinatorTest extends 
ConsumerCoordinatorTest {
     public EagerConsumerCoordinatorTest() {
         super(ConsumerPartitionAssignor.RebalanceProtocol.EAGER);
     }
+
+    // @Flaky("KAFKA-15900") -> testOutdatedCoordinatorAssignment (in super 
class)
 }
diff --git a/core/src/test/scala/integration/kafka/api/UserQuotaTest.scala 
b/core/src/test/scala/integration/kafka/api/UserQuotaTest.scala
index 5a5fb83aab5..598444a5deb 100644
--- a/core/src/test/scala/integration/kafka/api/UserQuotaTest.scala
+++ b/core/src/test/scala/integration/kafka/api/UserQuotaTest.scala
@@ -42,6 +42,8 @@ class UserQuotaTest extends BaseQuotaTest with SaslSetup {
     quotaTestClients.waitForQuotaUpdate(defaultProducerQuota, 
defaultConsumerQuota, defaultRequestQuota)
   }
 
+  // @Flaky("KAFKA-8073") -> testThrottledProducerConsumer (in super class)
+
   @AfterEach
   override def tearDown(): Unit = {
     super.tearDown()

Reply via email to