From 384eb16805ef8f7520f46cc6def25e71495bd6bd Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Tue, 25 Feb 2020 03:32:15 +0800 Subject: [PATCH] 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 , Guozhang Wang --- .../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 48431547aec..8320ffff182 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",