Function mz_kafka_util::admin::delete_topic

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

Like delete_existing_topic but allow topic to be already deleted