class Kafka::Instance

• Kafka::Instance
• Reference
• Object

Defined in:

kafka/instance.cr

Constructors

• .new(config : Kafka::Config, type : Kafka::Type)

Instance Method Summary

• #close
• #closed=(closed : Bool)
• #closed? : Bool
• #config : Kafka::Config
• #config=(config : Kafka::Config)
• #to_unsafe : LibRdKafka::Kafka

Constructor Detail

Instance Method Detail