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()