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