Skip to main content
CrystalDocs
Search documentation
Search
Browse Docs
CrystalShards
About
module
Kafka
Constants
Log = ::
Log
.for("crafka")
MAX_ERR_LEN = 160
VERSION = "0.7.0"
Class methods
librdkafka_version
Source
version_info
Source
Nested types
Kafka::Config
Kafka::Consumer
Kafka::ConsumerException
Kafka::KafkaException
Kafka::Message
Kafka::Producer
Kafka::ProducerException