v0.6.0

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

v0.5.0

Added

• Add #topic method to Kafka::Message. Thanks @oozzal!

v0.4.2

• Test with Crystal 1.11.2

v0.4.1

Added

• Fix to prevent exception when Delivery Report string is null pointer

v0.4.0

Added

• Call rd_kafka_poll automatically in Kafka::Producer. See documentation for details.

v0.3.3

Bump shard.yml version

v0.3.2

Bump shard.yml version