How do you create a path if it does not exist.
CuratorFramework    client =
CuratorFrameworkFactory.newClient("dzoo01:2181/kafka", new
ExponentialBackoffRetry(1000, 3));

path= '/name/offset/event-capture/topic';

I check if path exists
if(curatorFramework.checkExists().forPath(path) == null){
    curatorFramework.create().forPath(path)
}

will that code snippet create znode?


Thanks,
Vadim

Reply via email to