extract_pulsar_message_id_data_from_meta
risingwave_
connector
2.7.0-alpha
In risingwave_
connector::
parser::
utils
risingwave_connector
::
parser
::
utils
Function
extract_
pulsar_
message_
id_
data_
from_
meta
Copy item path
Source
pub fn extract_pulsar_message_id_data_from_meta( meta: &
SourceMeta
, ) ->
Option
<DatumRef<'_>>