KAFKA-14133: Replace EasyMock with Mockito in WorkerCoordinatorTest a…

…nd RootResourceTest (#12509) Reviewers: Mickael Maison <mickael.maison@gmail.com>, Dalibor Plavcic <dalibor.os@proton.me>
apache · Aug 22, 2022 · ddb7fdd · ddb7fdd
1 parent 519d8ac
commit ddb7fdd
Show file tree

Hide file tree

Showing 4 changed files with 89 additions and 160 deletions.
diff --git a/...runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java b/...runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java
@@ -373,10 +373,10 @@ public WorkerCoordinatorMetrics(Metrics metrics, String metricGrpPrefix) {
 
             metrics.addMetric(metrics.metricName("assigned-connectors",
                               this.metricGrpName,
-                              "The number of connector instances currently assigned to this consumer"), numConnectors);
+                              "The number of connector instances currently assigned to this worker"), numConnectors);
             metrics.addMetric(metrics.metricName("assigned-tasks",
                               this.metricGrpName,
-                              "The number of tasks currently assigned to this consumer"), numTasks);
+                              "The number of tasks currently assigned to this worker"), numTasks);
         }
     }