risingwave_connector::source::kafka::private_link

Function insert_privatelink_broker_rewrite_map

Source 
pub fn insert_privatelink_broker_rewrite_map(
    with_options: &mut BTreeMap<String, String>,
    svc: Option<&PrivateLinkService>,
    privatelink_endpoint: Option<String>,
) -> ConnectorResult<()>