diff --git a/tests/kafkatest/tests/core/throttling_test.py b/tests/kafkatest/tests/core/throttling_test.py index 586bac9c634..4a8327ebb0a 100644 --- a/tests/kafkatest/tests/core/throttling_test.py +++ b/tests/kafkatest/tests/core/throttling_test.py @@ -53,7 +53,7 @@ class ThrottlingTest(ProduceConsumeValidateTest): # ensure that the consumer is fully started before the producer starts # so that we don't miss any messages. This timeout ensures the sufficient # condition. - self.consumer_init_timeout_sec = 20 + self.consumer_init_timeout_sec = 60 self.num_brokers = 6 self.num_partitions = 3 self.kafka = KafkaService(test_context,