@Override
    public void updateBrokerStatus(int clusterId, Map<String, TopicFuture> pendingTopic) {
        MasterEntry masterEntry = masterRepository.findMasterEntryByClusterIdEquals(clusterId);
        if (masterEntry != null) {
            try {
                TubeHttpBrokerInfoList brokerInfoList = requestBrokerStatus(masterEntry);
                if (brokerInfoList != null) {
                    handleAddingTopic(masterEntry, brokerInfoList, pendingTopic);
                }
            } catch (Exception ex) {
                log.error("exception caught while requesting broker status", ex);
            }
        } else {
            log.error("cannot get master ip by clusterId {}, please check it", clusterId);
        }
    }
Adding topic is an async operation, so this method should
1. check whether pendingTopic contains topic that has failed/succeeded to be added.
2. async add topic to tubemq cluster

@param brokerInfoList - broker list
@param pendingTopic - topicMap
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/NodeServiceImpl.java