This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch 2.4 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.4 by this push: new 44fbd96 KAFKA-9599 create unique sensor to record group rebalance (#8159) 44fbd96 is described below commit 44fbd96de890a33cb51bb9d051ff396d070c6e8c Author: Chia-Ping Tsai <chia7...@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 <dja...@confluent.io>, Guozhang Wang <wangg...@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 2e2358d..7b69632 100644 --- a/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala +++ b/core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala @@ -75,7 +75,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",