public static void validateZkNameSpace(String zkConnect, ZkClient zkClient) {
    ConnectStringParser parser = new ConnectStringParser(zkConnect);

    String path = parser.getChrootPath();
    if (Strings.isNullOrEmpty(path)) {
      return; // no namespace path
    }

    LOG.info("connectString = " + zkConnect + "; path =" + path);

    // if namespace specified (path above) but "/" does not exists, we will fail
    if (!zkClient.exists("/")) {
      throw new SamzaException("Zookeeper namespace: " + path + " does not exist for zk at " + zkConnect);
    }
  }
if ZkConnectString contains namespace path at the end, but it does not exist we should fail
@param zkConnect - connect string
@param zkClient - zkClient object to talk to the ZK
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtilsFactory.java