Function mz_kafka_util::admin::ensure_topic

source ยท 
pub async fn ensure_topic<'a, C>(
    client: &'a AdminClient<C>,
    admin_opts: &AdminOptions,
    new_topic: &'a NewTopic<'a>,
) -> Result<bool, CreateTopicError>
where
    C: ClientContext,
Expand description

Like create_new_topic but allow topic to already exist