Skip to content

v0.6.0

Choose a tag to compare

@ukdave ukdave released this 18 Dec 15:01
· 16 commits to main since this release

Added

  • Add Kafka.version_info and Kafka.librdkafka_version methods.

Changed

  • Update Kafka::Consumer#poll and Kafka::Consumer#each to automatically raise a Kafka::ConsumerException if the message is an error. Pass raise_on_error: false to maintain the previous behaviour.

Full Changelog: v0.5.0...v0.6.0