Function mz_testdrive::action::kafka::verify_data::get_topic

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