mz_testdrive::action::kafka::verify_data

Function get_topic

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