diff --git a/src/v/kafka/group_probe.h b/src/v/kafka/group_probe.h index 0ba5da9272f7c..606c698d7fe48 100644 --- a/src/v/kafka/group_probe.h +++ b/src/v/kafka/group_probe.h @@ -78,11 +78,10 @@ class group_offset_probe { _public_metrics.add_group( prometheus_sanitize::metrics_name("kafka:consumer:group"), {sm::make_gauge( - "committed_offset", - [this] { return _offset; }, - sm::description("Consumer group committed offset"), - labels) - .aggregate({sm::shard_label})}); + "committed_offset", + [this] { return _offset; }, + sm::description("Consumer group committed offset"), + labels)}); } private: @@ -130,15 +129,13 @@ class group_probe { "consumers", [this] { return _members.size(); }, sm::description("Number of consumers in a group"), - labels) - .aggregate({sm::shard_label}), + labels), sm::make_gauge( "topics", [this] { return _offsets.size(); }, sm::description("Number of topics in a group"), - labels) - .aggregate({sm::shard_label})}); + labels)}); } private: