You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sc...@apache.org on 2025/10/28 22:16:07 UTC

(kafka) branch trunk updated: MINOR: Disable testShareGroupMaxSizeConfigExceeded and mark testAcknowledgementCommitCallbackThrowsException as Flaky (#20786)

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 <sj...@confluent.io>
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 <as...@confluent.io>
---
 .../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 = {