Function mz_coord::sink_connection::register_kafka_topic

async fn register_kafka_topic(
    client: &AdminClient<MzClientContext>, 
    topic: &str, 
    partition_count: i32, 
    replication_factor: i32, 
    succeed_if_exists: bool, 
    retention: KafkaSinkConnectionRetention
) -> Result<(), CoordError>