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 dce420d4..babee7c6 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 @@ -87,16 +87,20 @@ public class KubernetesDiscoveryClient implements DiscoveryClient { final Map serviceMetadata = new HashMap<>(); KubernetesDiscoveryProperties.Metadata metadataProps = properties.getMetadata(); if(metadataProps.isAddLabels()) { - serviceMetadata.putAll( - getMapWithPrefixedKeys( - service.getMetadata().getLabels(), metadataProps.getLabelsPrefix()) - ); + Map labelMetadata = getMapWithPrefixedKeys( + service.getMetadata().getLabels(), metadataProps.getLabelsPrefix()); + if (log.isDebugEnabled()) { + log.debug("Adding label metadata: "+labelMetadata); + } + serviceMetadata.putAll(labelMetadata); } if(metadataProps.isAddAnnotations()) { - serviceMetadata.putAll( - getMapWithPrefixedKeys( - service.getMetadata().getAnnotations(), metadataProps.getAnnotationsPrefix()) - ); + Map annotationMetadata = getMapWithPrefixedKeys( + service.getMetadata().getAnnotations(), metadataProps.getAnnotationsPrefix()); + if (log.isDebugEnabled()) { + log.debug("Adding annotation metadata: "+annotationMetadata); + } + serviceMetadata.putAll(annotationMetadata); } for (EndpointSubset s : subsets) { @@ -106,9 +110,11 @@ public class KubernetesDiscoveryClient implements DiscoveryClient { Map ports = s.getPorts().stream() .filter(port -> !StringUtils.isEmpty(port.getName())) .collect(toMap(EndpointPort::getName, port -> Integer.toString(port.getPort()))); - endpointMetadata.putAll( - getMapWithPrefixedKeys(ports, metadataProps.getPortsPrefix()) - ); + Map portMetadata = getMapWithPrefixedKeys(ports, metadataProps.getPortsPrefix()); + if (log.isDebugEnabled()) { + log.debug("Adding port metadata: "+portMetadata); + } + endpointMetadata.putAll(portMetadata); } List addresses = s.getAddresses();