@Override
    public boolean delConsumeCtrlConf(String operator,
            String groupName, String topicName,
            StringBuilder strBuff, ProcessResult result) {
        Integer topicLockId = null;
        Integer groupLockId = null;
        GroupConsumeCtrlEntity curEntity;
        String printPrefix = "[delConsumeCtrlConf], ";
        // execute delete operation
        try {
            // lock topicName meta-lock
            topicLockId = metaRowLock.getLock(null,
                    StringUtils.getBytesUtf8(topicName), true);
            try {
                // lock groupName meta-lock
                groupLockId = metaRowLock.getLock(null,
                        StringUtils.getBytesUtf8(groupName), true);
                // check consume control configure exist
                curEntity = consumeCtrlMapper.getConsumeCtrlByGroupAndTopic(groupName, topicName);
                if (curEntity == null) {
                    result.setSuccResult(null);
                    return result.isSuccess();
                }
                consumeCtrlMapper.delGroupConsumeCtrlConf(groupName, topicName, strBuff, result);
            } finally {
                if (groupLockId != null) {
                    metaRowLock.releaseRowLock(groupLockId);
                }
            }
        } catch (Throwable e) {
            return logExceptionInfo(e, printPrefix, strBuff, result);
        } finally {
            if (topicLockId != null) {
                metaRowLock.releaseRowLock(topicLockId);
            }
        }
        // print log to file
        if (result.isSuccess()) {
            strBuff.append(printPrefix).append(operator)
                    .append(" deleted consume control configure: ").append(curEntity);
            logger.info(strBuff.toString());
            strBuff.delete(0, strBuff.length());
        }
        return result.isSuccess();
    }
Add or Update consume control configure info

@param chkConsistent     whether order operation condition
@param isAddOpOrOnlyAdd  the operation type,
@param entity            the entity need to operation
@param strBuff           the string buffer
@param result            the process result return
@return true if success otherwise false
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsMetaConfigMapperImpl.java