risingwave_connector::sink::mqtt

Function get_topic_field_index_path

source 
fn get_topic_field_index_path(
    schema: &Schema,
    topic_field: &str,
) -> Result<Vec<usize>>