Function mz_kafka_util::admin::delete_existing_topic

pub async fn delete_existing_topic<'a, C>(
    client: &'a AdminClient<C>,
    admin_opts: &AdminOptions,
    topic: &'a str,
) -> Result<(), DeleteTopicError>
where
    C: ClientContext,

Deletes a Kafka topic and waits for it to be reported absent in the broker metadata.

This function is a wrapper around AdminClient::delete_topics that attempts to ensure the topic deletion has propagated throughout the Kafka cluster before returning.

This function does not return successfully unless it can observe the metadata not containing the newly-created topic in a call to rdkafka::client::Client::fetch_metadata