Merge pull request #32 from alibaba/master

merge

common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZkClientx.java

@@ -34,8 +34,8 @@ public class ZkClientx extends ZkClient {
         return clients.get(servers);
     }
 
-    public static ZkClientx removeZkClient(String servers) {
-        return clients.remove(servers);
+    public static void clearClients() {
+        clients.clear();
     }
 
     public ZkClientx(String serverstring){

deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java

@@ -522,6 +522,8 @@ public class CanalController {
         if (instanceConfigMonitors != null) {
             instanceConfigMonitors.clear();
         }
+
+        ZkClientx.clearClients();
     }
 
     private void initCid(String path) {