Review: Add missing runloopTimeout config in test

zio · Jun 17, 2023 · a75bf02 · a75bf02
1 parent 4e1bf9a
commit a75bf02
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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