private void handleAddingExistTopics(MasterEntry masterEntry, TubeHttpBrokerInfoList brokerInfoList,
            String topic, List<Integer> topicBrokerList) {
        // remove brokers which have been added.
        List<Integer> configurableBrokerIdList =
                brokerInfoList.getConfigurableBrokerIdList();
        configurableBrokerIdList.removeAll(topicBrokerList);
        // add topic to satisfy max broker number.
        Set<String> singleTopic = new HashSet<>();
        singleTopic.add(topic);
        int maxBrokers = Math.min(maxConfigurableBrokerSize, configurableBrokerIdList.size());
        nodeService.configBrokersForTopics(masterEntry, singleTopic,
                configurableBrokerIdList, maxBrokers);
    }
Add topic info

@param clusterId this is the cluster id
@param topicTasks topic info
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/executors/AddTopicExecutor.java