private void createBaseZNodes() throws ZooKeeperConnectionException {
        try {
            // Create all the necessary "directories" of znodes
            ZKUtil.createAndFailSilent(this, baseZNode);
        } catch (KeeperException e) {
            throw new ZooKeeperConnectionException(
                    prefix("Unexpected KeeperException creating base node"), e);
        }
    }
Instantiate a ZooKeeper connection and watcher.
<p/>
Descriptive string that is added to zookeeper sessionid and used as identifier for this
instance.
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/zookeeper/ZooKeeperWatcher.java