zio/zio-kafka v0.8.0

0.8.0

on GitHub

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!