diff --git a/core/src/main/scala/kafka/controller/ControllerState.scala b/core/src/main/scala/kafka/controller/ControllerState.scala index dc0df2f3e46..c89cb18d516 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 {