Function coord::sink_connector::register_kafka_topic

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