class
Kafka::Handle
- Kafka::Handle
- Reference
- Object
Direct Known Subclasses
Defined in:
kafka/handle.crConstructors
-
.new(type : LibKafka::TypeT, conf : Configuration)
Creates a new Kafka handle and starts its operation according to the specified type.
- .new(handle : LibKafka::RdKafkaT)
Instance Method Summary
-
#brokers_add(brokerlist : String)
Adds one or more brokers to the kafka handle's list of initial bootstrap brokers.
-
#destroy
Destroy Kafka handle.
-
#member_id
Returns this client's broker-assigned group member id.
-
#name : String
Returns Kafka handle name.
-
#outq_len
Returns the current out queue length.
-
#poll(timeout_ms = 1000)
Polls the provided kafka handle for events.
- #set_log_level(level : LibC::Int)
- #to_unsafe : LibKafka::RdKafkaT
Constructor Detail
def self.new(type : LibKafka::TypeT, conf : Configuration)
#
Creates a new Kafka handle and starts its operation according to the specified type.
Instance Method Detail
def brokers_add(brokerlist : String)
#
Adds one or more brokers to the kafka handle's list of initial bootstrap brokers.
def poll(timeout_ms = 1000)
#
Polls the provided kafka handle for events. Events will cause application provided callbacks to be called.