diff --git a/spring-cloud-kubernetes-discovery/src/main/java/org/springframework/cloud/kubernetes/discovery/KubernetesDiscoveryClient.java b/spring-cloud-kubernetes-discovery/src/main/java/org/springframework/cloud/kubernetes/discovery/KubernetesDiscoveryClient.java index 3aae79ff..a988867f 100644 --- a/spring-cloud-kubernetes-discovery/src/main/java/org/springframework/cloud/kubernetes/discovery/KubernetesDiscoveryClient.java +++ b/spring-cloud-kubernetes-discovery/src/main/java/org/springframework/cloud/kubernetes/discovery/KubernetesDiscoveryClient.java @@ -130,8 +130,7 @@ public class KubernetesDiscoveryClient implements DiscoveryClient { if (!subsets.isEmpty()) { final Service service = this.client.services().inNamespace(namespace) .withName(serviceId).get(); - final Map serviceMetadata = this.getServiceMetadata(namespace, - serviceId); + final Map serviceMetadata = this.getServiceMetadata(service); KubernetesDiscoveryProperties.Metadata metadataProps = this.properties .getMetadata(); @@ -175,10 +174,7 @@ public class KubernetesDiscoveryClient implements DiscoveryClient { return instances; } - private Map getServiceMetadata(String namespace, String serviceId) { - final Service service = this.client.services().inNamespace(namespace) - .withName(serviceId).get(); - + private Map getServiceMetadata(Service service) { final Map serviceMetadata = new HashMap<>(); KubernetesDiscoveryProperties.Metadata metadataProps = this.properties .getMetadata();