private Tuple2<Boolean, Boolean> updBrokerTopicInfo(int brokerId,
            Map<String, TopicInfo> topicInfoMap) {
        boolean isChanged = false;
        boolean isFastSync = true;
        Tuple2<Boolean, Boolean> retResult = new Tuple2<>();
        if (topicInfoMap == null || topicInfoMap.isEmpty()) {
            retResult.setF0AndF1(isChanged, isFastSync);
            return retResult;
        }
        ConcurrentHashMap<Integer, TopicInfo> curTopicInfoView;
        for (TopicInfo newTopicInfo : topicInfoMap.values()) {
            if (newTopicInfo == null) {
                continue;
            }
            curTopicInfoView = topicConfInfoMap.get(newTopicInfo.getTopic());
            if (curTopicInfoView == null) {
                isFastSync = false;
                continue;
            }
            TopicInfo curTopicInfo = curTopicInfoView.get(brokerId);
            if (curTopicInfo == null) {
                isFastSync = false;
                continue;
            }
            curTopicInfo.updAndJudgeTopicInfo(newTopicInfo, retResult);
            if (retResult.getF0() && !isChanged) {
                isChanged = true;
            }
            if (retResult.getF1() && isFastSync) {
                isFastSync = false;
            }
        }
        retResult.setF0AndF1(isChanged, isFastSync);
        return retResult;
    }
Remove broker all topic info

@param brokerId  need removed broker
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/BrokerTopicInfoView.java