github zio/zio-kafka v2.6.0

latest releases: v2.8.2, v2.8.1, v2.8.0...
11 months ago

Noticeable Changes

  • Automatically merge commits by @erikvanoosten in #1073
    In this PR zio-kafka automatically merges all commits that were generated in the course of a single run of the runloop. This frees users from having to merge streams and do the commit merging themselves.
  • Add processing timeout at the stream level by @erikvanoosten in #1009
    Say good bye to the runloop-timeout! From this version on we respect Kafka configuration max.poll.interval.ms. When a stream does not consume any records for max.poll.interval.ms or longer (while records are available), the stream will be interrupted and the consumer closed. This allows another member of the consumer group to take over the work.
  • Add tuning options and docs by @erikvanoosten in #1081
    A new tuning guide on https://zio.dev/zio-kafka/.
  • Enable the consumer to commit an offset with metadata by @flavienbert in #1067

See the PR descriptions for more information.

All Changes

New Contributors

Full Changelog: v2.5.0...v2.6.0

Don't miss a new zio-kafka release

NewReleases is sending notifications on new releases.