From 4c5023096bf558f228d5cf9a99f610cc5050eb06 Mon Sep 17 00:00:00 2001
From: huzongtang <huzongtang@cmss.chinamobile.com>
Date: Thu, 11 Apr 2019 09:31:08 +0800
Subject: [PATCH] adjust variable for RebalanceServer Class.

---
 .../connect/runtime/service/RebalanceService.java             | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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.