@Override
    public BrokerProcessResult addOrUpdBrokerConfig(boolean isAddOp, BrokerConfEntity entity,
            StringBuilder strBuff, ProcessResult result) {
        // check current status
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            return new BrokerProcessResult(entity.getBrokerId(), entity.getBrokerIp(), result);
        }
        // add or update broker meta-data
        if (!metaConfigMapper.addOrUpdBrokerConfig(isAddOp, entity, strBuff, result)) {
            return new BrokerProcessResult(entity.getBrokerId(), entity.getBrokerIp(), result);
        }
        BrokerConfEntity curEntity =
                metaConfigMapper.getBrokerConfByBrokerId(entity.getBrokerId());
        // update broker static information
        this.tMaster.getBrokerRunManager().updBrokerStaticInfo(curEntity);
        if (isAddOp) {
            // add system topic if absent
            metaConfigMapper.addSystemTopicDeploy(curEntity.getBrokerId(),
                    curEntity.getBrokerPort(), curEntity.getBrokerIp(), strBuff);
        }
        // auto trigger configure sync
        triggerBrokerConfDataSync(curEntity.getBrokerId(), strBuff, result);
        // return result
        return new BrokerProcessResult(curEntity.getBrokerId(), curEntity.getBrokerIp(), 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