risingwave_meta::stream::source_manager::worker

Function extract_prop_from_new_source

source 
fn extract_prop_from_new_source(
    source: &Source,
) -> ConnectorResult<ConnectorProperties>