Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
svroonland committed Apr 14, 2024
1 parent 35d8412 commit 5a139ba
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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)))
Expand Down

0 comments on commit 5a139ba

Please sign in to comment.