<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.7.0</version>
</dependency>
String connectionString = "localhost:2181";
int sessionTimeout = 5000;
ZooKeeper zookeeper = new ZooKeeper(connectionString, sessionTimeout, null);
String path = "/mynode";
byte[] data = "Hello, ZooKeeper!".getBytes();
CreateMode mode = CreateMode.PERSISTENT;
zookeeper.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, mode);
String path = "/mynode";
byte[] newData = "Hello, ZooKeeper!".getBytes();
int version = zookeeper.exists(path, false).getVersion();
zookeeper.setData(path, newData, version);
String path = "/mynode";
int version = zookeeper.exists(path, false).getVersion();
zookeeper.delete(path, version);
String path = "/mynode";
Watcher watcher = new Watcher() {
@Override
public void process(WatchedEvent event) {
System.out.println("Node event: " + event.getType());
}
};
zookeeper.exists(path, watcher);
