class

Kafka::Handle

Inherits Reference < Object

Constructors

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

Creates a new Kafka handle and starts its operation according to the specified type.

Source
new(handle : LibKafka::RdKafkaT)
Source

Instance methods

brokers_add(brokerlist : String)

Adds one or more brokers to the kafka handle's list of initial bootstrap brokers.

Source
destroy

Destroy Kafka handle.

Source
member_id

Returns this client's broker-assigned group member id.

Source
name

Returns Kafka handle name.

Source
outq_len

Returns the current out queue length.

Source
poll(timeout_ms = 1000)

Polls the provided kafka handle for events. Events will cause application provided callbacks to be called.

Source
set_log_level(level : LibC::Int)
Source
to_unsafe
Source