private static byte[] getDataInternal(ZooKeeperWatcher zkw, String zkNode, Stat stat,
            boolean watcherSet) throws KeeperException {
        try {
            byte[] data = zkw.getRecoverableZooKeeper().getData(zkNode, zkw, stat);
            logRetrievedMsg(zkw, zkNode, data, watcherSet);
            return data;
        } catch (KeeperException.NoNodeException e) {
            if (logger.isDebugEnabled()) {
                logger.debug(zkw.prefix("Unable to get data of zkNode " + zkNode + " "
                        + "because node does not exist (not an error)"));
            }
            return null;
        } catch (KeeperException e) {
            logger.warn(zkw.prefix("Unable to get data of zkNode " + zkNode), e);
            zkw.keeperException(e);
            return null;
        } catch (InterruptedException e) {
            logger.warn(zkw.prefix("Unable to get data of zkNode " + zkNode), e);
            zkw.interruptedException(e);
            return null;
        }
    }
delete the specified zkNode.

@param zkw   zk reference
@param zkNode path of node
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/zookeeper/ZKUtil.java