Function mz_storage_client::sink::ensure_kafka_topic

async fn ensure_kafka_topic<C>(
    client: &AdminClient<C>,
    topic: &str,
    partition_count: i32,
    replication_factor: i32,
    retention: KafkaSinkConnectionRetention
) -> Result<(), Error>where
    C: ClientContext,