diff --git a/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala b/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala index fc60cab1d0d..bbc4e6c350c 100644 --- a/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala +++ b/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala @@ -24,8 +24,8 @@ import org.junit.jupiter.params.provider.MethodSource import java.util.concurrent.ExecutionException -@Timeout(600) -class PlaintextConsumerTest extends BaseConsumerTest { +@Timeout(60) +class PlaintextConsumerTest extends AbstractConsumerTest { @Flaky("KAFKA-18031") @ParameterizedTest(name = TestInfoUtils.TestWithParameterizedGroupProtocolNames)