@Override
    public TopicProcessResult updTopicDeployStatusInfo(BaseEntity opEntity, int brokerId,
            String topicName, TopicStsChgType chgType,
            StringBuilder strBuff, ProcessResult result) {
        // check current status
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            return new TopicProcessResult(brokerId, topicName, result);
        }
        // check broker configure exist
        BrokerConfEntity brokerConf = getBrokerConfByBrokerId(brokerId);
        if (brokerConf == null) {
            result.setFailResult(DataOpErrCode.DERR_NOT_EXIST.getCode(),
                    strBuff.append("Not found broker configure record by brokerId=")
                            .append(brokerId)
                            .append(", please create the broker's configure first!").toString());
            strBuff.delete(0, strBuff.length());
            return new TopicProcessResult(brokerId, topicName, result);
        }
        // get topic deploy configure record
        TopicDeployEntity curEntity = metaConfigMapper.getConfiguredTopicInfo(brokerId, topicName);
        if (curEntity == null) {
            result.setFailResult(DataOpErrCode.DERR_NOT_EXIST.getCode(),
                    strBuff.append("Not found the topic ").append(topicName)
                            .append("'s deploy configure in broker=").append(brokerId)
                            .append(", please confirm the configure first!").toString());
            strBuff.delete(0, strBuff.length());
            return new TopicProcessResult(brokerId, topicName, result);
        }
        // map topic status
        TopicStatus topicStatus;
        if (chgType == TopicStsChgType.STATUS_CHANGE_SOFT_DELETE) {
            topicStatus = TopicStatus.STATUS_TOPIC_SOFT_DELETE;
        } else if (chgType == TopicStsChgType.STATUS_CHANGE_REMOVE) {
            topicStatus = TopicStatus.STATUS_TOPIC_SOFT_REMOVE;
        } else {
            topicStatus = TopicStatus.STATUS_TOPIC_OK;
        }
        // add or update topic deploy information
        if (metaConfigMapper.updTopicDeployStatusInfo(opEntity,
                brokerId, topicName, topicStatus, strBuff, result)) {
            // trigger data sync
            triggerBrokerConfDataSync(brokerId, strBuff, result);
        }
        return new TopicProcessResult(brokerId, topicName, result);
    }
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