private void updateConfigResult(MasterEntry masterEntry, Map<String, TopicTaskEntry> pendingTopic) {
        TubeHttpBrokerInfoList brokerInfoList = nodeService.requestBrokerStatus(masterEntry);
        if (ValidateUtils.isNull(brokerInfoList)) {
            return;
        }
        for (String topic : pendingTopic.keySet()) {
            TubeHttpTopicInfoList topicInfoList = topicService.requestTopicConfigInfo(masterEntry, topic);
            if (ValidateUtils.isNull(topicInfoList)) {
                continue;
            }
            // get broker list by topic request
            Set<Integer> topicBrokerSet =
                    new HashSet<>(topicInfoList.getTopicBrokerIdList());
            List<Integer> allBrokerIdList = brokerInfoList.getAllBrokerIdList();

            // determine if all topics has been added
            TopicTaskEntry topicTask = pendingTopic.get(topic);
            updateTopicRepo(topicBrokerSet, allBrokerIdList, topicTask);
        }
    }
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