diff --git a/src/main/java/io/openmessaging/connect/runtime/service/RebalanceService.java b/src/main/java/io/openmessaging/connect/runtime/service/RebalanceService.java
index 0ee8fbc..007b962 100644
--- a/src/main/java/io/openmessaging/connect/runtime/service/RebalanceService.java
+++ b/src/main/java/io/openmessaging/connect/runtime/service/RebalanceService.java
@@ -47,7 +47,7 @@ public RebalanceService(RebalanceImpl rebalanceImpl, ConfigManagementService con
         this.rebalanceImpl = rebalanceImpl;
         this.configManagementService = configManagementService;
         this.clusterManagementService = clusterManagementService;
-        this.configManagementService.registerListener(new ConnectorConnectorConfigChangeListenerImpl());
+        this.configManagementService.registerListener(new ConnectorConfigChangeListenerImpl());
         this.clusterManagementService.registerListener(new WorkerStatusListenerImpl());
     }
 
@@ -79,7 +79,7 @@ public void onWorkerChange() {
         }
     }
 
-    class ConnectorConnectorConfigChangeListenerImpl implements ConfigManagementService.ConnectorConfigUpdateListener {
+    class ConnectorConfigChangeListenerImpl implements ConfigManagementService.ConnectorConfigUpdateListener {
 
         /**
          * When config change.