Noticeable Changes
- [Fix] Issue #856 is now fixed
- [Fix] After a call to
consumer.stopConsumption
, starting a new consumption with the same Consumer instance was not doing anything (fixed in #857) - [Breaking] The
Producer.withProducerService(f)
function has been removed. You need to replace it withZIO.serviceWithZIO[Producer](f)
All Changes
- Micro-optimisation for manual consumption mode: Use only 1 IO to execute all the
c.seek
calls indoSeekForNewPartitions
@guizmaii (#900) - Using a Consumer without consuming shouldn't throw a
RunloopTimeout
exception @guizmaii (#857) - Update scalafmt-core to 3.7.5 @github-actions (#952)
- Update sbt to 1.9.1 @github-actions (#948)
- Clean some code of
LiveTransactionalProducer
andProducer
@guizmaii (#947) - Update zio-kafka, zio-kafka-testkit to 2.4.0 @github-actions (#946)
- Update README.md @zio-assistant (#945)