Improvements
Zio-kafka became a little bit faster by doing less work when there is no rebalance.
Really large and tiny messages are better described in the tuning documentation, and ConsumerSettings.withoutPartitionPreFetching
was introduced to make it easier to disable pre-fetching.
Previously, in some use cases, you could end up with a live-lock trying to get access to the underlying java consumer. This should no longer happen.
Breaking changes
Zio-kafka no longer supports scala 2.12. Scala 2.13 has been available for 4½ year so everyone has had plenty of time to move to a more modern scala version. (#1104)
This release has some some minor breaking changes:
- The diagnostics events for rebalances have been improved in an incompatible way (#1102)
- Jackson was removed as a dependency (#1096)
partitionPreFetchBufferLimit
is now 0-based instead of 1-based (#1091)
Changes
- Update scalafmt-core to 3.7.17 @zio-scala-steward (#1111)
- Make access to the java consumer fair @flavienbert (#1109)
- Extend tuning docs @erikvanoosten (#1110)
- Protect agains user diagnostics, better rebalance events @erikvanoosten (#1102)
- Drop support for scala 2.12 @erikvanoosten (#1104)
- Update zio-streams, zio-test-sbt to 2.0.19 @zio-scala-steward (#1101)
- Update zio, zio-streams, zio-test, ... to 2.0.19 @zio-scala-steward (#1100)
- Update zio-logging-slf4j, ... to 2.1.15 @zio-scala-steward (#1099)
- Track latest completed commit offset per partition @erikvanoosten (#1097)
- Always end streams in rebalance listener, support lost partitions @erikvanoosten (#1089)
- Remove jackson dependency @erikvanoosten (#1096)
- Make
partitionPreFetchBufferLimit
value0
disable prefetching @erikvanoosten (#1091) - Update zio-kafka, zio-kafka-testkit to 2.6.0 @zio-scala-steward (#1092)
- Update README.md @zio-assistant (#1090)
- Prevent double logging in tests @erikvanoosten (#1088)