import org.apache.zookeeper.*; public class ZooKeeperExample { private static final String ZOOKEEPER_ADDRESS = "localhost:2181"; private static final int SESSION_TIMEOUT = 5000; public static void main(String[] args) throws Exception { ZooKeeper zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, null); String path = "/example"; byte[] data = "Hello, ZooKeeper!".getBytes(); CreateMode mode = CreateMode.PERSISTENT; zooKeeper.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, mode); zooKeeper.close(); } }