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 9ea9059957..bd1434511a 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 @@ -385,7 +385,7 @@ object ConsumerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom { } .forkScoped _ <- produceMany(topic, kvs) - _ <- stop.await *> fib.interrupt.debug + _ <- stop.await *> fib.interrupt offset <- Consumer.committed(Set(new TopicPartition(topic, 0))).map(_.values.head) } yield offset }.provideSomeLayer[Kafka with Producer](consumer(client, Some(group)))