private boolean triggerBrokerConfDataSync(Set<String> topicNameSet,
            StringBuilder strBuff,
            ProcessResult result) {
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            return result.isSuccess();
        }
        Set<Integer> brokerIdSet =
                metaConfigMapper.getDeployedBrokerIdByTopic(topicNameSet);
        if (brokerIdSet.isEmpty()) {
            result.setSuccResult();
            return result.isSuccess();
        }
        BrokerRunStatusInfo runStatusInfo;
        BrokerRunManager brokerRunManager = this.tMaster.getBrokerRunManager();
        for (Integer brokerId : brokerIdSet) {
            if (brokerId == null) {
                continue;
            }
            runStatusInfo = brokerRunManager.getBrokerRunStatusInfo(brokerId);
            if (runStatusInfo == null) {
                continue;
            }
            runStatusInfo.notifyDataChanged();
        }
        logger.info(strBuff.append("[Meta data] trigger broker syncStatus info for")
                .append(" maxMsgSize modify, brokerId set is ").append(brokerIdSet)
                .toString());
        strBuff.delete(0, strBuff.length());
        result.setSuccResult(null);
        return result.isSuccess();
    }
Reload topic's deploy config info

@param topicNameSet  the topic name set
@param strBuff       the string buffer
@param result        the process return result
@return true if success otherwise false
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/DefaultMetaDataService.java