rd_kafka_queue_get_partition

@returns a reference to the partition's queue, or NULL if partition is invalid.

Use rd_kafka_queue_destroy() to loose the reference.

@remark rd_kafka_queue_destroy() MUST be called on this queue

@remark This function only works on consumers.

extern (C) nothrow @nogc
rd_kafka_queue_get_partition
(,
const char* topic
,
int32_t partition
)

Meta