Function rdkafka_wrap::bindings::rd_kafka_mock_cluster_new
pub unsafe extern "C" fn rd_kafka_mock_cluster_new(
rk: *mut rd_kafka_s,
broker_cnt: i32
) -> *mut rd_kafka_mock_cluster_spub unsafe extern "C" fn rd_kafka_mock_cluster_new(
rk: *mut rd_kafka_s,
broker_cnt: i32
) -> *mut rd_kafka_mock_cluster_s