import org.apache.zookeeper.*; public class ZooKeeperExample implements Watcher { private static final String ZOOKEEPER_ADDRESS = "localhost:2181"; private static final int SESSION_TIMEOUT = 5000; private static final String NODE_PATH = "/example"; public static void main(String[] args) throws Exception { ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, new ZooKeeperExample()); String createdNodePath = zooKeeper.create(NODE_PATH, "example data".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); System.out.println("Created node: " + createdNodePath); zooKeeper.setData(NODE_PATH, "new data".getBytes(), -1); System.out.println("Updated node data: " + new String(zooKeeper.getData(NODE_PATH, false, null))); zooKeeper.delete(NODE_PATH, -1); System.out.println("Deleted node."); zooKeeper.close(); } @Override public void process(WatchedEvent event) { System.out.println("Received event: " + event.getType()); } }