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 065e6600a542e..ff840ebf2ea7a 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 void testClassicConsumerSubscribeInvalidTopicCanUnsubscribe() throws Inte } @ClusterTest - public void testAsyncConsumerClassicConsumerSubscribeInvalidTopicCanUnsubscribe() throws InterruptedException { + public void testAsyncConsumerSubscribeInvalidTopicCanUnsubscribe() throws InterruptedException { testSubscribeInvalidTopicCanUnsubscribe(GroupProtocol.CONSUMER); }