public int getMaxTopicBrokerCnt(Set<String> topicSet,
            Set<Integer> enableSubBrokerIdSet) {
        int tmpSize;
        int maxCount = -1;
        ConcurrentHashMap<Integer, TopicInfo> topicInfoView;
        if (topicSet == null || topicSet.isEmpty()) {
            return maxCount;
        }
        for (String topic : topicSet) {
            if (topic == null) {
                continue;
            }
            topicInfoView = topicConfInfoMap.get(topic);
            if (topicInfoView == null
                    || topicInfoView.isEmpty()) {
                continue;
            }
            tmpSize = 0;
            for (TopicInfo topicInfo : topicInfoView.values()) {
                if (topicInfo == null
                        || !enableSubBrokerIdSet.contains(topicInfo.getBrokerId())) {
                    continue;
                }
                tmpSize++;
            }
            if (maxCount < tmpSize) {
                maxCount = tmpSize;
            }
        }
        return maxCount;
    }
Get the maximum number of broker distributions of topic

@param topicSet need query topic set
@param enableSubBrokerIdSet  need filtered broker id set
@return   max configure broker count for each topic
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/BrokerTopicInfoView.java