@Override
    public List<TopicProcessResult> addOrUpdTopicCtrlConf(boolean isAddOp,
            Map<String, TopicCtrlEntity> entityMap,
            StringBuilder strBuff, ProcessResult result) {
        List<TopicProcessResult> retInfo = new ArrayList<>();
        // check current status
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            for (String topicName : entityMap.keySet()) {
                retInfo.add(new TopicProcessResult(0, topicName, result));
            }
            return retInfo;
        }
        if (isAddOp) {
            for (TopicCtrlEntity entity : entityMap.values()) {
                metaConfigMapper.addOrUpdTopicCtrlConf(isAddOp, entity, strBuff, result);
                retInfo.add(new TopicProcessResult(0, entity.getTopicName(), result));
            }
        } else {
            TopicCtrlEntity curEntity;
            Set<String> changedTopicSet = new HashSet<>();
            for (TopicCtrlEntity entity : entityMap.values()) {
                curEntity = metaConfigMapper.getTopicCtrlByTopicName(entity.getTopicName());
                if (curEntity != null) {
                    if (curEntity.getMaxMsgSizeInB() != entity.getMaxMsgSizeInB()) {
                        changedTopicSet.add(entity.getTopicName());
                    }
                }
                metaConfigMapper.addOrUpdTopicCtrlConf(isAddOp, entity, strBuff, result);
                retInfo.add(new TopicProcessResult(0, entity.getTopicName(), result));
            }
            if (!changedTopicSet.isEmpty()) {
                triggerBrokerConfDataSync(changedTopicSet, strBuff, result);
            }
        }
        return retInfo;
    }
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