pub unsafe extern "C" fn rd_kafka_queue_io_event_enable( rkqu: *mut rd_kafka_queue_s, fd: i32, payload: *const c_void, size: usize, )