risingwave_connector::source::kafka::private_link

Function get_property_required

source 
fn get_property_required(
    with_properties: &BTreeMap<String, String>,
    property: &str,
) -> ConnectorResult<String>