rd_kafka_queue_new

@brief Create a new message queue.

See rd_kafka_consume_start_queue(), rd_kafka_consume_queue(), et.al.

extern (C) nothrow @nogc

rd_kafka_queue_t*

rd_kafka_queue_new

(

)

Meta

Source

See Implementation

deimos rdkafka aliases

enums

functions

manifest constants

structs

variables

RD_KAFKA_PARTITION_UA