From b2f0d92c45349327c9a1093ba4004ec5ada5dd4a Mon Sep 17 00:00:00 2001 From: Sanskar Jhajharia Date: Tue, 25 Feb 2025 15:46:00 +0530 Subject: [PATCH] [MINOR] Fix the docs for share group metric functions (#19023) The last commit in this class mistakenly described the functions to be for Streams Groups. Just a minor update. Reviewers: Andrew Schofield , Apoorv Mittal , Sushant Mahajan --- .../group/metrics/GroupCoordinatorMetricsShard.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java index c312932c113..8725eee133e 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java @@ -160,7 +160,7 @@ public class GroupCoordinatorMetricsShard implements CoordinatorMetricsShard { * that updates the metrics in {@link org.apache.kafka.coordinator.group.GroupCoordinatorShard}. * Breaking this will result in inconsistent behavior. * - * @param shareGroupGauges The map counting the number of streams groups in each state. + * @param shareGroupGauges The map counting the number of share groups in each state. */ public void setShareGroupGauges(Map shareGroupGauges) { this.shareGroupGauges = shareGroupGauges; @@ -267,7 +267,7 @@ public class GroupCoordinatorMetricsShard implements CoordinatorMetricsShard { } /** - * @return The total number of streams groups. + * @return The total number of share groups. */ public long numShareGroups() { return shareGroupGauges.values().stream()