@@ -45,8 +45,8 @@ public void testMetricNames() {
45
45
Set <String > expected = Set .of (
46
46
"kafka.controller:type=ControllerEventManager,name=EventQueueProcessingTimeMs" ,
47
47
"kafka.controller:type=ControllerEventManager,name=EventQueueTimeMs" ,
48
+ "kafka.controller:type=ControllerEventManager,name=AvgIdleRatio" ,
48
49
"kafka.controller:type=KafkaController,name=ActiveControllerCount" ,
49
- "kafka.controller:type=KafkaController,name=AvgIdleRatio" ,
50
50
"kafka.controller:type=KafkaController,name=EventQueueOperationsStartedCount" ,
51
51
"kafka.controller:type=KafkaController,name=EventQueueOperationsTimedOutCount" ,
52
52
"kafka.controller:type=KafkaController,name=LastAppliedRecordLagMs" ,
@@ -194,7 +194,7 @@ public void testYammerTimeRatioIdleTimeTracking() {
194
194
MetricsRegistry registry = new MetricsRegistry ();
195
195
MockTime time = new MockTime ();
196
196
try (QuorumControllerMetrics metrics = new QuorumControllerMetrics (Optional .of (registry ), time , 9000 )) {
197
- Gauge <Double > avgIdleRatio = (Gauge <Double >) registry .allMetrics ().get (metricName ("KafkaController " , "AvgIdleRatio" ));
197
+ Gauge <Double > avgIdleRatio = (Gauge <Double >) registry .allMetrics ().get (metricName ("ControllerEventManager " , "AvgIdleRatio" ));
198
198
199
199
// No idle time recorded yet
200
200
assertEquals (1.0 , avgIdleRatio .value ());
0 commit comments