c/metrics: Added kafka_advertised_listeners to metrics report

Signed-off-by: Michael Boquard <[email protected]>

src/v/cluster/metrics_reporter.cc

@@ -249,6 +249,14 @@ metrics_reporter::build_metrics_snapshot() {
         }
 
         metrics.uptime_ms = report->local_state.uptime / 1ms;
+        auto& advertised_listeners
+          = nm->get().broker.kafka_advertised_listeners();
+        metrics.advertised_listeners.reserve(advertised_listeners.size());
+        std::transform(
+          advertised_listeners.begin(),
+          advertised_listeners.end(),
+          std::back_inserter(metrics.advertised_listeners),
+          [](const model::broker_endpoint& ep) { return ep.address; });
     }
     auto& topics = _topics.local().topics_map();
     snapshot.topic_count = 0;
@@ -646,6 +654,8 @@ void rjson_serialize(
         rjson_serialize(w, d);
     }
     w.EndArray();
+    w.Key("kafka_advertised_listeners");
+    rjson_serialize(w, nm.advertised_listeners);
 
     w.EndObject();
 }

src/v/cluster/metrics_reporter.h

@@ -20,6 +20,7 @@
 #include "model/metadata.h"
 #include "security/fwd.h"
 #include "utils/prefix_logger.h"
+#include "utils/unresolved_address.h"
 
 #include <seastar/core/abort_source.hh>
 #include <seastar/core/gate.hh>
@@ -58,6 +59,7 @@ class metrics_reporter {
         cluster_version logical_version{invalid_version};
         std::vector<node_disk_space> disks;
         uint64_t uptime_ms{0};
+        std::vector<net::unresolved_address> advertised_listeners;
     };
 
     struct metrics_snapshot {

tests/rptest/tests/metrics_reporter_test.py

@@ -171,6 +171,7 @@ def assert_fields_are_the_same(metadata, field):
         assert all('uptime_ms' in n for n in nodes_meta)
         assert all('is_alive' in n for n in nodes_meta)
         assert all('disks' in n for n in nodes_meta)
+        assert all('kafka_advertised_listeners' in n for n in nodes_meta)
 
         # Check cluster UUID and creation time survive a restart
         for n in self.redpanda.nodes: