Я пытался использовать куратор apache для zookeeper, но не смог добиться прогресса. Все, что я ищу, это установить наблюдателя на узле zk и прослушивать все изменения данных на этом конкретном узле. Я написал простую программу, чтобы попробовать это, но я не получаю никаких событий. Вот мой код:
CuratorFramework curator = new ZookeeperClient(zkHosts).getConnection();
CompletableFuture.runAsync(() -> {
CuratorWatcher curatorWatcher = event -> System.out.println("Watched event: " + event);
try {
curator.getChildren().usingWatcher(curatorWatcher).forPath(NODE_PATH);
} catch (Exception e) {
e.printStackTrace();
}
});
CompletableFuture.runAsync(() -> {
try {
curator.setData().forPath(NODE_PATH, "randomdata1".getBytes());
curator.setData().forPath(NODE_PATH, "randomdata2".getBytes());
} catch (Exception e) {
e.printStackTrace();
}
});
Спасибо за помощь!