(kafka) branch trunk updated: KAFKA-20565 Fix flaky test testAutoCommitSentBeforePositionUpdate timeout (#22256)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 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 159d696005e KAFKA-20565 Fix flaky test 
testAutoCommitSentBeforePositionUpdate timeout (#22256)
159d696005e is described below

commit 159d696005eeddc6eb386aa9f50caa7d2b1a9147
Author: Murali Basani <muralidhar.bas...@aiven.io>
AuthorDate: Wed May 20 03:17:58 2026 +0200

    KAFKA-20565 Fix flaky test testAutoCommitSentBeforePositionUpdate timeout 
(#22256)
    
    Ref : https://issues.apache.org/jira/browse/KAFKA-20565
    
    Reverting parameterization (for this test only) to only CLASSIC, as
    prepareRebalance stages CLASSIC protocol RPCs
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
 
b/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
index 589a1354aed..7dcd5826b32 100644
--- 
a/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
+++ 
b/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
@@ -1407,8 +1407,9 @@ public class KafkaConsumerTest {
         assertNull(committed.get(tp1));
     }
 
+    // NOTE: the rebalance flow in prepareRebalance is specific to the CLASSIC 
consumer.
     @ParameterizedTest
-    @EnumSource(GroupProtocol.class)
+    @EnumSource(value = GroupProtocol.class, names = "CLASSIC")
     public void testAutoCommitSentBeforePositionUpdate(GroupProtocol 
groupProtocol) {
         ConsumerMetadata metadata = createMetadata(subscription);
         MockClient client = new MockClient(time, metadata);