Fmt

zio · Jan 13, 2025 · ad2ae68 · ad2ae68
1 parent 404f7df
commit ad2ae68
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
@@ -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"))