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.