String connectString = "localhost:2181"; int sessionTimeout = 5000; Watcher watcher = new Watcher() { @Override public void process(WatchedEvent event) { } }; ZooKeeper zooKeeper = new ZooKeeper(connectString, sessionTimeout, watcher); String path = "/myNode"; byte[] data = "Hello, ZooKeeper!".getBytes(); List<ACL> acl = ZooDefs.Ids.OPEN_ACL_UNSAFE; CreateMode createMode = CreateMode.PERSISTENT; String createdPath = zooKeeper.create(path, data, acl, createMode); String path = "/myNode"; boolean watch = true; Stat stat = new Stat(); byte[] data = zooKeeper.getData(path, watch, stat); String dataStr = new String(data); String path = "/myNode"; byte[] newData = "Updated data".getBytes(); int version = stat.getVersion(); Stat updatedStat = zooKeeper.setData(path, newData, version); String path = "/myNode"; int version = updatedStat.getVersion(); void deleteNode(String path) throws KeeperException, InterruptedException { zooKeeper.delete(path, version); }