ZooKeeper zk = new ZooKeeper("localhost:2181", 5000, new Watcher() { public void process(WatchedEvent event) { } }); byte[] data = zk.getData("/path", true, null); zk.create("/node", data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); zk.exists("/node", true); public void process(WatchedEvent event) { }