class

Kafka::Consumer

Inherits Kafka::Handle < Reference < Object

Constructors

new(conf : Configuration)
Source
new(handle : LibKafka::RdKafkaT)
Source