Function mz_testdrive::action::kafka::verify_topic::get_topic

async fn get_topic(
    sink: &str,
    topic_field: &str,
    state: &mut State
) -> Result<String, Error>