From a4f808741b689a1d9dd72ca29d6e3b8c07238322 Mon Sep 17 00:00:00 2001 From: Ryan Baxter Date: Wed, 10 Feb 2021 13:45:40 -0500 Subject: [PATCH] Fixes #731 --- .../client/discovery/KubernetesInformerDiscoveryClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java b/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java index f8ccd5a6..e8d21a54 100644 --- a/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java +++ b/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java @@ -130,7 +130,7 @@ public class KubernetesInformerDiscoveryClient implements DiscoveryClient, Initi } V1EndpointPort port = subset.getPorts() != null && subset.getPorts().size() == 1 ? subset.getPorts().get(0) : subset.getPorts().stream() - .filter(p -> this.properties.getPrimaryPortName().equalsIgnoreCase(p.getName())).findFirst() + .filter(p -> p.getName().equalsIgnoreCase(this.properties.getPrimaryPortName())).findFirst() .orElseThrow(IllegalStateException::new); List addresses = subset.getAddresses(); if (this.properties.isIncludeNotReadyAddresses()