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);