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 9f6a0956d..8983813be 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
@@ -1360,7 +1360,7 @@ object ConsumerSpec extends ZIOSpecDefaultSlf4j with KafkaRandom {
               ZIO.logAnnotate("consumer", name) {
                 ZIO.scoped {
                   (for {
-                    consumer <- ZIO.service[Consumer]
+                    consumer                <- ZIO.service[Consumer]
                     consumedMessagesCounter <- Ref.make(0)
                     _ <- consumedMessagesCounter.get
                            .flatMap(consumed => ZIO.logDebug(s"Consumed so far: $consumed"))