Function librdkafka_sys::rd_kafka_poll [] [src]

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