This is an automated email from the ASF dual-hosted git repository.
manikumar 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 e0fb246 MINOR: Preserve backwards-compatibility by renaming the
AlterPartitionReassignment metric to PartitionReassignment
e0fb246 is described below
commit e0fb2464d1ec00495af09cd6273e1e61be900c6f
Author: Stanislav Kozlovski <[email protected]>
AuthorDate: Wed Oct 30 15:17:14 2019 +0530
MINOR: Preserve backwards-compatibility by renaming the
AlterPartitionReassignment metric to PartitionReassignment
In
https://github.com/apache/kafka/commit/18d4e57f6e8c67ffa7937fc855707d3a03cc165a#diff-394389922df5210adf43a8b7064cc4ffL61
we unintentionally renamed the metric with the previous changes to
reassignments
Author: Stanislav Kozlovski <[email protected]>
Reviewers: Manikumar Reddy <[email protected]>
Closes #7606 from stanislavkozlovski/minor-partition-reassignment-metric
(cherry picked from commit 2dba8803f77fc2000f15933aeac9a63a4ee10288)
Signed-off-by: Manikumar Reddy <[email protected]>
---
core/src/main/scala/kafka/controller/ControllerState.scala | 2 ++
1 file changed, 2 insertions(+)
diff --git a/core/src/main/scala/kafka/controller/ControllerState.scala
b/core/src/main/scala/kafka/controller/ControllerState.scala
index dc0df2f..c89cb18 100644
--- a/core/src/main/scala/kafka/controller/ControllerState.scala
+++ b/core/src/main/scala/kafka/controller/ControllerState.scala
@@ -60,6 +60,8 @@ object ControllerState {
case object AlterPartitionReassignment extends ControllerState {
def value = 5
+
+ override def rateAndTimeMetricName: Option[String] =
Some("PartitionReassignmentRateAndTimeMs")
}
case object AutoLeaderBalance extends ControllerState {
