From bf2b22cd3b9e6505cc2a4d06308f760e4099d08a Mon Sep 17 00:00:00 2001
From: Raphael Mazelier <raphael@adikteev.com>
Date: Wed, 26 Feb 2025 11:40:07 +0100
Subject: [PATCH] fix: cassandra4 and 5 compat fix

---
 .../com/zegelin/cassandra/exporter/FactoriesSupplier.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 -> {