diff --git a/zio-kafka-test/src/test/scala/zio/kafka/consumer/ConsumerSpec.scala b/zio-kafka-test/src/test/scala/zio/kafka/consumer/ConsumerSpec.scala
index 416e5f8932..4d1cad5d8f 100644
--- a/zio-kafka-test/src/test/scala/zio/kafka/consumer/ConsumerSpec.scala
+++ b/zio-kafka-test/src/test/scala/zio/kafka/consumer/ConsumerSpec.scala
@@ -1068,7 +1068,7 @@ object ConsumerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
           def test(diagnostics: Diagnostics) =
             for {
               clientId <- randomClient
-              settings <- consumerSettings(clientId = clientId)
+              settings <- consumerSettings(clientId = clientId, runloopTimeout = 500.millis)
               _        <- Consumer.make(settings, diagnostics = diagnostics)
               _        <- ZIO.sleep(1.second)
             } yield assertCompletes