module Kafka

Defined in:

crafka.cr
kafka/config.cr
kafka/consumer.cr
kafka/consumer/rebalance.cr
kafka/message.cr
kafka/producer.cr
kafka/producer/delivery_report.cr
kafka/producer/statistics.cr

Constant Summary

Log = ::Log.for("crafka")

MAX_ERR_LEN = 160

VERSION = "0.6.0"

Class Method Summary

• .librdkafka_version
• .version_info

Class Method Detail