kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From maniku...@apache.org
Subject [kafka] branch 2.4 updated: MINOR: Preserve backwards-compatibility by renaming the AlterPartitionReassignment metric to PartitionReassignment
Date Wed, 30 Oct 2019 09:48:20 GMT
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 <stanislav_kozlovski@outlook.com>
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 <stanislav_kozlovski@outlook.com>
    
    Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
    
    Closes #7606 from stanislavkozlovski/minor-partition-reassignment-metric
    
    (cherry picked from commit 2dba8803f77fc2000f15933aeac9a63a4ee10288)
    Signed-off-by: Manikumar Reddy <manikumar@confluent.io>
---
 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 {


Mime
View raw message