utils/src/service_discovery.rs

@@ -33,7 +33,7 @@ pub async fn get_kube_service_endpoints_by_dns(port_name: &str, service_protocol
     let (config, options) = read_system_conf()?;
     let resolver = TokioAsyncResolver::tokio(config, options);
 
-    let srv_name = format!("_{}._{}._{}", port_name, service_protocol, service_name);
+    let srv_name = format!("_{}._{}.{}", port_name, service_protocol, service_name);
     let srv_record = resolver.srv_lookup(&srv_name).await?;
 
     let mut endpoints = Vec::new();