public void validatePaths(String[] paths) {
    for (String path : paths) {
      if (!zkClient.exists(path)) {
        zkClient.createPersistent(path, true);
      }
    }
  }
verify that given paths exist in ZK
@param paths - paths to verify or create
samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java