class Kafka::Queue

• Kafka::Queue
• Reference
• Object

Defined in:

kafka/queue.cr

Constructors

• .new(rk : Consumer | Producer)

  Create a new message queue.

Instance Method Summary

• #destroy

  Destroys queue, purging all of the enqueued messages.

• #to_unsafe : LibKafka::RdKafkaQueueT

Constructor Detail

Instance Method Detail