Changed

• Raise an error when trying to use a consumer after it has been closed
• Add Consumer#stop method to stop an each loop
• Add crystal versions 1.15.1 and 1.16.3 to test matrix

Fixed

• Use ::sleep(Time::Span) instead of ::sleep(Number) to fix deprecations warnings with Crystal >= 1.14

Full Changelog: v0.6.0...v0.7.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

Added

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

• Test with Crystal 1.11.2

Added

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

Added

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