class Kafka::Queue

Defined in:

kafka/queue.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(rk : Consumer | Producer) #

Create a new message queue.


[View source]

Instance Method Detail

def destroy #

Destroys queue, purging all of the enqueued messages.


[View source]
def to_unsafe : LibKafka::RdKafkaQueueT #

[View source]