@Override
    public boolean addOrUpdClusterDefSetting(BaseEntity opEntity, int brokerPort,
            int brokerTlsPort, int brokerWebPort,
            int maxMsgSizeMB, int qryPriorityId,
            EnableStatus flowCtrlEnable, int flowRuleCnt,
            String flowCtrlInfo, TopicPropGroup topicProps,
            StringBuilder strBuff, ProcessResult result) {
        // check current status
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            return result.isSuccess();
        }
        return metaConfigMapper.addOrUpdClusterDefSetting(opEntity, brokerPort, brokerTlsPort,
                brokerWebPort, maxMsgSizeMB, qryPriorityId, flowCtrlEnable, flowRuleCnt,
                flowCtrlInfo, topicProps, strBuff, result);
    }
Check if consume target is authorization or not

@param groupName    checked group name
@param consumerId   checked consume id
@param enableFltCsmTopicSet    target consume topic set
@param reqTopicCondMap   consumer request filter items
@param strBuff        the print information string buffer
@param result         the process result return
@return true is authorized, false not
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/DefaultMetaDataService.java