rd_kafka_queue_get_consumer

@returns a reference to the librdkafka consumer queue. This is the queue served by rd_kafka_consumer_poll().

Use rd_kafka_queue_destroy() to loose the reference.

@remark rd_kafka_queue_destroy() MUST be called on this queue prior to calling rd_kafka_consumer_close().

extern (C) nothrow @nogc
rd_kafka_queue_get_consumer

Meta