zio/zio-kafka v0.5.0

on GitHub

Changes since 0.4.0:

• Manual topic/partition assignment (#66)
• Support for offset retrieval outside of Kafka (#104). Consumer.seek* methods have been deprecated in favour of this.
• Improved handling of fiber interrupts in AdminClient (#108)
• OffsetBatch.commitOrRetry to handle retriable commit exceptions (#81).
• New Consumer.committed method (#87)
• Fix issue with Revoked diagnostic event being emitted instead of Assigned (#87)
• Build for Scala 2.13 (#92)
• Upgrade to kafka 2.4.0 (#92, #107)
• Improved scaladoc and readme (#86, #89)

Internal changes:

• Move implementation classes to a private package (#80)
• Additional tests for Consumer (#87)
• Fix flaky tests (#104)
• Various dependency upgrades