public synchronized void ensureConnectivity(KeeperException e) {
        if (e != null && e.code() != KeeperException.Code.SESSIONEXPIRED) {
            return;
        }

        try {
            reconnectAfterExpiration();
        } catch (Throwable e1) {
            logger.error("[ZK_SESSION_EXPIRATION] reconnectAfterExpiration failed.", e1);
        }
    }
Filters the given node list by the given prefixes. This method is all-inclusive--if any
element in the node list starts with any of the given prefixes, then it is included in the
result.

@param nodes    the nodes to filter
@param prefixes the prefixes to include in the result
@return list of every element that starts with one of the prefixes
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/zookeeper/RecoverableZooKeeper.java