risingwave_
connector
2.4.0-alpha
In risingwave_
connector::
sink::
mqtt
risingwave_connector
::
sink
::
mqtt
Function
get_topic_field_index_path
Copy item path
Source
fn get_topic_field_index_path( schema: &Schema, topic_field: &
str
, ) ->
Result
<
Vec
<
usize
>>