Function rd_kafka_queue_get_main

Source
pub unsafe extern "C" fn rd_kafka_queue_get_main(
    rk: *mut rd_kafka_t,
) -> *mut rd_kafka_queue_t
Expand description

Returns a reference to the main librdkafka event queue. This is the queue served by rd_kafka_poll().

Use rd_kafka_queue_destroy() to loose the reference.