This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new b2f0d92c453 [MINOR] Fix the docs for share group metric functions
(#19023)
b2f0d92c453 is described below
commit b2f0d92c45349327c9a1093ba4004ec5ada5dd4a
Author: Sanskar Jhajharia <[email protected]>
AuthorDate: Tue Feb 25 15:46:00 2025 +0530
[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 <[email protected]>, Apoorv Mittal
<[email protected]>, Sushant Mahajan <[email protected]>
---
.../kafka/coordinator/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<ShareGroupState, Long>
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()
