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 7337631675a MINOR: Disable testShareGroupMaxSizeConfigExceeded and 
mark testAcknowledgementCommitCallbackThrowsException as Flaky (#20786)
7337631675a is described below

commit 7337631675aecfcdd339794a7086d4bab7b90037
Author: Sanskar Jhajharia <[email protected]>
AuthorDate: Wed Oct 29 03:46:00 2025 +0530

    MINOR: Disable testShareGroupMaxSizeConfigExceeded and mark 
testAcknowledgementCommitCallbackThrowsException as Flaky (#20786)
    
    Disabling the test to prevent flakiness in build.  Complete analysis @
    https://issues.apache.org/jira/browse/KAFKA-19840.
    
    Reviewers: Andrew Schofield <[email protected]>
---
 .../java/org/apache/kafka/clients/consumer/ShareConsumerTest.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
 
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
index 391796fc5dc..b75609e9ae9 100644
--- 
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
+++ 
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
@@ -58,6 +58,7 @@ 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;
@@ -66,6 +67,7 @@ import org.apache.kafka.server.share.SharePartitionKey;
 import org.apache.kafka.test.TestUtils;
 
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Timeout;
 
@@ -1619,6 +1621,7 @@ public class ShareConsumerTest {
      * Test to verify that the acknowledgement commit callback can throw an 
exception, and it is propagated
      * to the caller of poll().
      */
+    @Flaky("KAFKA-19840") // https://issues.apache.org/jira/browse/KAFKA-19840
     @ClusterTest
     public void testAcknowledgementCommitCallbackThrowsException() throws 
InterruptedException {
         alterShareAutoOffsetReset("group1", "earliest");
@@ -2333,6 +2336,7 @@ public class ShareConsumerTest {
         verifyShareGroupStateTopicRecordsProduced();
     }
 
+    @Disabled("KAFKA-19840") // 
https://issues.apache.org/jira/browse/KAFKA-19840
     @ClusterTest(
         brokers = 1,
         serverProperties = {

Reply via email to