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 = {