diff --git a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerSubscriptionTest.java b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerSubscriptionTest.java index 065e6600a54..ff840ebf2ea 100644 --- a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerSubscriptionTest.java +++ b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerSubscriptionTest.java @@ -576,7 +576,7 @@ public class PlaintextConsumerSubscriptionTest { } @ClusterTest - public void testAsyncConsumerClassicConsumerSubscribeInvalidTopicCanUnsubscribe() throws InterruptedException { + public void testAsyncConsumerSubscribeInvalidTopicCanUnsubscribe() throws InterruptedException { testSubscribeInvalidTopicCanUnsubscribe(GroupProtocol.CONSUMER); }