Skip to content

Commit 23fec88

Browse files
Merge pull request #23339 from ballard26/CORE-6746
Remove shard aggregation on consumer group metrics
2 parents aa51f0d + ca8cd1e commit 23fec88

File tree

1 file changed

+6
-9
lines changed

1 file changed

+6
-9
lines changed

src/v/kafka/server/group_probe.h

+6-9
Original file line numberDiff line numberDiff line change
@@ -77,11 +77,10 @@ class group_offset_probe {
7777
_public_metrics.add_group(
7878
prometheus_sanitize::metrics_name("kafka:consumer:group"),
7979
{sm::make_gauge(
80-
"committed_offset",
81-
[this] { return _offset; },
82-
sm::description("Consumer group committed offset"),
83-
labels)
84-
.aggregate({sm::shard_label})});
80+
"committed_offset",
81+
[this] { return _offset; },
82+
sm::description("Consumer group committed offset"),
83+
labels)});
8584
}
8685

8786
private:
@@ -129,15 +128,13 @@ class group_probe {
129128
"consumers",
130129
[this] { return _members.size(); },
131130
sm::description("Number of consumers in a group"),
132-
labels)
133-
.aggregate({sm::shard_label}),
131+
labels),
134132

135133
sm::make_gauge(
136134
"topics",
137135
[this] { return _offsets.size(); },
138136
sm::description("Number of topics in a group"),
139-
labels)
140-
.aggregate({sm::shard_label})});
137+
labels)});
141138
}
142139

143140
private:

0 commit comments

Comments
 (0)