kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 2.4 updated: KAFKA-9599 create unique sensor to record group rebalance (#8159)
Date Mon, 24 Feb 2020 19:39:35 GMT
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 <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 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",


Mime
View raw message