class Kafka::Consumer

Defined in:

kafka/consumer.cr

Constructors

Instance methods inherited from class Kafka::Handle

brokers_add(brokerlist : String) brokers_add, destroy destroy, member_id member_id, name : String name, outq_len outq_len, poll(timeout_ms = 1000) poll, set_log_level(level : LibC::Int) set_log_level, to_unsafe : LibKafka::RdKafkaT to_unsafe

Constructor methods inherited from class Kafka::Handle

new(type : LibKafka::TypeT, conf : Configuration)
new(handle : LibKafka::RdKafkaT) new

Constructor Detail

def self.new(conf : Configuration) #

[View source]
def self.new(handle : LibKafka::RdKafkaT) #

[View source]