Function librdkafka_sys::rd_kafka_consume_callback

pub unsafe extern fn rd_kafka_consume_callback(rkt: *mut rd_kafka_topic_t,
                                               partition: int32_t,
                                               timeout_ms: c_int,
                                               consume_cb: Option<unsafe extern fn(rkmessage: *mut rd_kafka_message_t, opaque: *mut c_void)>,
                                               opaque: *mut c_void)
                                               -> c_int