@Override
    public boolean delCleanedTopicDeployInfo(int brokerId, List<String> removedTopics,
            StringBuilder strBuff, ProcessResult result) {
        result.setSuccResult(null);
        if (removedTopics == null || removedTopics.isEmpty()) {
            return result.isSuccess();
        }
        // check current status
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            return result.isSuccess();
        }
        // delete deploy configure topic by topic
        Map<String, TopicDeployEntity> topicDeployMap = metaConfigMapper.getConfiguredTopicInfo(brokerId);
        if (topicDeployMap == null || topicDeployMap.isEmpty()) {
            return result.isSuccess();
        }
        boolean needSync2Broker = false;
        for (String topicName : removedTopics) {
            TopicDeployEntity topicEntity = topicDeployMap.get(topicName);
            if (topicEntity != null
                    && topicEntity.getTopicStatus() == TopicStatus.STATUS_TOPIC_SOFT_REMOVE) {
                if (metaConfigMapper.delTopicDeployInfo("system-self",
                        brokerId, topicName, strBuff, result)) {
                    needSync2Broker = true;
                }
            }
        }
        // sync change to broker node
        if (needSync2Broker) {
            return triggerBrokerConfDataSync(brokerId, strBuff, result);
        }
        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