(kafka) branch trunk updated: KAFKA-18033: Remove flaky tag in ShareConsumerTest (#18995)

[schofielaj]

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 7da1a6cbff0 KAFKA-18033: Remove flaky tag in ShareConsumerTest (#18995)
7da1a6cbff0 is described below

commit 7da1a6cbff055cd32ec2e00efdaa593fe13ab984
Author: Shivsundar R <s...@confluent.io>
AuthorDate: Fri Feb 21 08:50:08 2025 -0500

    KAFKA-18033: Remove flaky tag in ShareConsumerTest (#18995)
    
    3 tests which were marked flaky in ShareConsumerTest do not have any
    failure on trunk since the test was converted to use 
`ClusterTestExtensions`.
    
    Reviewers: Sushant Mahajan <smaha...@confluent.io>, Apoorv Mittal 
<apoorvmitta...@gmail.com>, Andrew Schofield <aschofi...@confluent.io>
---
 core/src/test/java/kafka/test/api/ShareConsumerTest.java | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/core/src/test/java/kafka/test/api/ShareConsumerTest.java 
b/core/src/test/java/kafka/test/api/ShareConsumerTest.java
index 51a5a8728dd..0ee38d8aba5 100644
--- a/core/src/test/java/kafka/test/api/ShareConsumerTest.java
+++ b/core/src/test/java/kafka/test/api/ShareConsumerTest.java
@@ -61,7 +61,6 @@ import org.apache.kafka.common.test.ClusterInstance;
 import org.apache.kafka.common.test.api.ClusterConfigProperty;
 import org.apache.kafka.common.test.api.ClusterTest;
 import org.apache.kafka.common.test.api.ClusterTestDefaults;
-import org.apache.kafka.common.test.api.Flaky;
 import org.apache.kafka.common.test.api.Type;
 import org.apache.kafka.common.utils.Utils;
 import org.apache.kafka.coordinator.group.GroupConfig;
@@ -390,7 +389,6 @@ public class ShareConsumerTest {
         }
     }
 
-    @Flaky("KAFKA-18033")
     @ClusterTest
     public void testAcknowledgementCommitCallbackInvalidRecordStateException() 
throws Exception {
         setup();
@@ -1079,7 +1077,6 @@ public class ShareConsumerTest {
         }
     }
 
-    @Flaky("KAFKA-18033")
     @ClusterTest
     public void testMultipleConsumersInGroupConcurrentConsumption()
             throws InterruptedException, ExecutionException, TimeoutException {
@@ -2027,7 +2024,6 @@ public class ShareConsumerTest {
         }
     )
     @Timeout(150)
-    @Flaky("KAFKA-18665")
     public void testComplexShareConsumer() throws Exception {
         setup();
         String topicName = "multipart";