New
v3.1.0
A brand new release targeting Kafka java client 4.1 (which is compatible with almost all older Kafka brokers). In this release we also increase support for slow consumers in combination with rebalance-safe-commits mode. See the documentation or PR #1576 for more details. Special thanks to @awethon for analyzing slow consumers in detail ❤️! These changes also benefit fast consumers that use rebalance-safe-commits as rebalances now take less time.
🚧 Breaking changes
- Despite the minor upgrade of the Kafka java client, zio-kafka 3.1.0 is not binary compatible with the 4.0 Kafka java client.
- The Kafka java client changed the Admin Client's API. These changes are mirrored in zio-kafka's wrapper and are not fully source (nor binary) compatible.
🚀 Changes
- Doc improvements by @erikvanoosten in https://github.com/zio/zio-kafka/pull/1548
- Remove workaround for kafka 4.1.0 by @erikvanoosten in https://github.com/zio/zio-kafka/pull/1550
- Update kafka-clients to 4.1.0 by @zio-scala-steward[bot] and @erikvanoosten in https://github.com/zio/zio-kafka/pull/1564 (Restores the workaroud for invisible partition changes that was removed in #1550.)
- Make rebalances faster, support slow consumers by @erikvanoosten in https://github.com/zio/zio-kafka/pull/1576