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

lianetm 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 241b6e6c6f2 KAFKA-17410: Disable 
testPollThrowsInterruptExceptionIfInterrupted for AsyncConsumer (#17172)
241b6e6c6f2 is described below

commit 241b6e6c6f26291a9498891aea163ba63b15afac
Author: TengYao Chi <[email protected]>
AuthorDate: Thu Sep 12 18:41:05 2024 +0800

    KAFKA-17410: Disable testPollThrowsInterruptExceptionIfInterrupted for 
AsyncConsumer (#17172)
    
    Reviewers: Lianet Magrans <[email protected]>
---
 .../test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java  | 2 +-
 1 file changed, 1 insertion(+), 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 8aee21775d3..77c0264849a 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
@@ -1273,7 +1273,7 @@ public class KafkaConsumerTest {
     }
 
     @ParameterizedTest
-    @EnumSource(GroupProtocol.class)
+    @EnumSource(value = GroupProtocol.class, names = "CLASSIC")
     public void testPollThrowsInterruptExceptionIfInterrupted(GroupProtocol 
groupProtocol) {
         final ConsumerMetadata metadata = createMetadata(subscription);
         final MockClient client = new MockClient(time, metadata);

Reply via email to