Skip to main content

get_topic

mz_testdrive::action::kafka::verify_topic

Function get_topic 

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