@Override
    public BrokerProcessResult delBrokerConfInfo(String operator, boolean rsvData,
            int brokerId, StringBuilder strBuff,
            ProcessResult result) {
        // check current status
        if (!metaConfigMapper.checkStoreStatus(true, result)) {
            return new BrokerProcessResult(brokerId, "", result);
        }
        // query the operated object
        BrokerConfEntity curEntry = metaConfigMapper.getBrokerConfByBrokerId(brokerId);
        if (curEntry == null) {
            result.setFullInfo(true,
                    DataOpErrCode.DERR_SUCCESS.getCode(),
                    DataOpErrCode.DERR_SUCCESS.getDescription());
            return new BrokerProcessResult(brokerId, "", result);
        }
        // check broker's manage status
        if (curEntry.getManageStatus().isOnlineStatus()) {
            result.setFailResult(DataOpErrCode.DERR_ILLEGAL_STATUS.getCode(),
                    "Broker manage status is online, please offline first!");
            return new BrokerProcessResult(brokerId, curEntry.getBrokerIp(), result);
        }
        // check broker node running status
        BrokerRunManager brokerRunManager = tMaster.getBrokerRunManager();
        BrokerRunStatusInfo runStatusInfo =
                brokerRunManager.getBrokerRunStatusInfo(brokerId);
        if (runStatusInfo != null
                && curEntry.getManageStatus() == ManageStatus.STATUS_MANAGE_OFFLINE
                && runStatusInfo.inProcessingStatus()) {
            result.setFailResult(DataOpErrCode.DERR_ILLEGAL_STATUS.getCode(),
                    strBuff.append("Illegal value: the broker is processing offline event by brokerId=")
                            .append(brokerId).append(", please offline first and try later!").toString());
            strBuff.delete(0, strBuff.length());
            return new BrokerProcessResult(brokerId, curEntry.getBrokerIp(), result);
        }
        // delete broker configure
        if (metaConfigMapper.delBrokerConfInfo(operator, brokerId, rsvData, strBuff, result)) {
            // delete broker static information
            brokerRunManager.delBrokerStaticInfo(brokerId);
            if (runStatusInfo != null) {
                // release broker run information
                brokerRunManager.releaseBrokerRunInfo(brokerId, runStatusInfo.getCreateId(), false);
            }
        }
        return new BrokerProcessResult(brokerId, curEntry.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