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()