diff --git a/common/src/main/java/com/zegelin/cassandra/exporter/FactoriesSupplier.java b/common/src/main/java/com/zegelin/cassandra/exporter/FactoriesSupplier.java
index 2d88503..3362836 100644
--- a/common/src/main/java/com/zegelin/cassandra/exporter/FactoriesSupplier.java
+++ b/common/src/main/java/com/zegelin/cassandra/exporter/FactoriesSupplier.java
@@ -470,8 +470,8 @@ private Factory connectionMetric(final FactoryBuilder.CollectorConstructor colle
                     final HashMap<String, String> labels = new HashMap<>();
 
                     {
-                        final String endpoint = keyPropertyList.get("scope"); // IP address of other node
-                        labels.putAll(metadataFactory.endpointLabels(endpoint));
+                        final String endpointAndPort = keyPropertyList.get("scope"); // IP address of other node
+                        labels.putAll(metadataFactory.endpointLabels(endpointAndPort.split("_")[0]));
                     }
 
                     labels.computeIfAbsent("task_type", k -> {