补充获取ZK的namespace的方法

Author: zengqiao

km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/ZookeeperUtils.java

@@ -16,7 +16,7 @@ public class ZookeeperUtils {
      * 解析ZK地址
      * @see ConnectStringParser
      */
-    public static List<Tuple<String, Integer>> connectStringParser(String connectString) throws Exception {
+    public static List<Tuple<String, Integer>> connectStringParser(String connectString) {
         List<Tuple<String, Integer>> ipPortList = new ArrayList<>();
 
         if (connectString == null) {
@@ -55,5 +55,14 @@ public static List<Tuple<String, Integer>> connectStringParser(String connectStr
         return ipPortList;
     }
 
+    public static String getNamespace(String zookeeperAddress) {
+        int index = zookeeperAddress.indexOf('/');
+        String namespace = "/";
+        if (index != -1) {
+            namespace = zookeeperAddress.substring(index);
+        }
+        return namespace;
+    }
+
 
 }