0.12.1

This release upgrades to ZIO v1.0.2, Kafka clients v2.6.0 and fixes a bug due to a change in the behavior of ZStream#collectWhileSuccess.

0.12.0

Notable changes:

• Upgrade to ZIO 1.0.0 🎉 by @iravid
• Add simplified Producer#produce/produceAsync overloads (#174) by @cipriansofronia

0.11.0

This release upgrades ZIO to 1.0.0-RC21.

0.10.1

Notable changes:

• Add describeConfigs to AdminClient (#168) by @egast
• Add support for configuring Serde instances (#177) by @igrebenik
• Avoid the use of ZStream#mapM to preserve the chunks (#186) by @iravid

0.10.0

Notable changes from 0.9.0:

• Add fuctions to serialize and deserialize to option (#172) by @egast
• Upgrade to ZIO RC20 (#184) by @iravid

0.9.0

Changes from 0.8.0:

• Consumer.make and Producer.make now return ZManaged values (#161 by @LGLO)
• Producer.produce/produceChunk now produce the record/chunk immediately. The previous implementation returned RIO[R with Blocking, Task[RecordMetadata]], which was potentially more efficient but also easy to miss the inner layer. The old behavior is available under produceAsync/produceChunkAsync. (#165 by @LGLO)
• ZIO has been upgraded to 1.0.0-RC19. (#170 by @iravid)

0.8.0

Notable changes:

• Eager polling: the consumer will now immediately poll whenever there's demand from the stream. This improves performance considerably (by up to 15x in some benchmarks).
• Simplified interface for the consumer: the type parameters have been removed from the consumer. This improves the ergonomics of working with the module accessors (Consumer.subscribeAnd, etc.). The tradeoff is that the Serde instances are now specified on Consumer.partitionedStream/plainStream.

Thank you @svroonland for contributing a refactor to the internal consumer runloop!

0.7.0

Adds support for ZIO 1.0.0-RC18-2.

0.6.2

Fixes a bug in which the consumer was prematurely interrupted.

0.6.1

Resolves an issue with IllegalStateException being thrown during rebalances (#134 by @iravid).