Function librdkafka_sys::rd_kafka_consumer_poll

pub unsafe extern fn rd_kafka_consumer_poll(rk: *mut rd_kafka_t,
                                            timeout_ms: c_int)
                                            -> *mut rd_kafka_message_t