You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by li...@apache.org on 2024/09/12 10:41:12 UTC
(kafka) branch trunk updated: KAFKA-17410: Disable testPollThrowsInterruptExceptionIfInterrupted for AsyncConsumer (#17172)
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 <ki...@gmail.com>
AuthorDate: Thu Sep 12 18:41:05 2024 +0800
KAFKA-17410: Disable testPollThrowsInterruptExceptionIfInterrupted for AsyncConsumer (#17172)
Reviewers: Lianet Magrans <lm...@confluent.io>
---
.../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);