public void rmvExpiredUnavailableBrokers() {
        long curTime = System.currentTimeMillis();
        Set<Integer> expiredBrokers = new HashSet<>();
        for (Map.Entry<Integer, Long> entry : brokerUnavailableMap.entrySet()) {
            if (entry.getKey() == null || entry.getValue() == null) {
                continue;
            }
            if (curTime - entry.getValue() > unAvailableFbdDurationMs) {
                expiredBrokers.add(entry.getKey());
            }
        }
        if (!expiredBrokers.isEmpty()) {
            for (Integer brokerId : expiredBrokers) {
                Long lastAddTime = brokerUnavailableMap.get(brokerId);
                if (lastAddTime == null) {
                    continue;
                }
                if (curTime - lastAddTime > unAvailableFbdDurationMs) {
                    brokerUnavailableMap.remove(brokerId, lastAddTime);
                }
            }
        }
    }
Remove unavailable records
All unavailable records will be removed after the specified time
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/RpcServiceFactory.java