Function mz_testdrive::action::kafka::wait_topic::check_topic_exists

pub(crate) async fn check_topic_exists(
    topic: &str,
    state: &State
) -> Result<(), Error>