Function librdkafka_sys::rd_kafka_consume_queue

pub unsafe extern fn rd_kafka_consume_queue(rkqu: *mut rd_kafka_queue_t,
                                            timeout_ms: c_int)
                                            -> *mut rd_kafka_message_t