Function kafka_util::admin::ensure_topic

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

Like create_new_topic but allow topic to already exist