mz_testdrive::action::kafka::wait_topic

Function check_topic_exists

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