This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch 2.5
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.5 by this push:
new 4b39238 KAFKA-9599 create unique sensor to record group rebalance (#8159)
4b39238 is described below
commit 4b3923867322ec8e260de640d316ba737a59cd27
Author: Chia-Ping Tsai <chia7712@gmail.com>
AuthorDate: Tue Feb 25 03:32:15 2020 +0800
KAFKA-9599 create unique sensor to record group rebalance (#8159)
The "offset deletion" and "group rebalance" should not be recorded by the same sensor
since they are totally different.
The code is introduced by #7276.
Reviewers: David Jacot <djacot@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
---
core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala b/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
index 4843154..8320fff 100644
--- a/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
+++ b/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
@@ -74,7 +74,7 @@ class GroupCoordinator(val brokerId: Int,
"group-coordinator-metrics",
"The total number of administrative deleted offsets")))
- val groupCompletedRebalanceSensor = metrics.sensor("OffsetDeletions")
+ val groupCompletedRebalanceSensor = metrics.sensor("CompletedRebalances")
groupCompletedRebalanceSensor.add(new Meter(
metrics.metricName("group-completed-rebalance-rate",
|