@Override
    public boolean delTopicDeployInfo(String operator, int brokerId, String topicName,
            StringBuilder strBuff, ProcessResult result) {
        TopicDeployEntity curEntity;
        String printPrefix = "[delTopicDeployConf], ";
        Integer topicLockId = null;
        Integer brokerLockId = null;
        // execute add or update operation
        try {
            // lock topicName meta-lock
            topicLockId = metaRowLock.getLock(null,
                    StringUtils.getBytesUtf8(topicName), true);
            try {
                // lock brokerId meta-lock
                brokerLockId = metaRowLock.getLock(null,
                        StringUtils.getBytesUtf8(String.valueOf(brokerId)), true);
                // check broker configure exist
                BrokerConfEntity brokerEntity = brokerConfigMapper.getBrokerConfByBrokerId(brokerId);
                if (brokerEntity == null) {
                    result.setSuccResult(null);
                    return result.isSuccess();
                }
                // check topic deploy configure
                curEntity = topicDeployMapper.getTopicConf(brokerId, topicName);
                if (curEntity == null) {
                    result.setSuccResult(null);
                    return result.isSuccess();
                }
                // delete record
                topicDeployMapper.delTopicDeployConf(curEntity.getRecordKey(), strBuff, result);
            } finally {
                if (brokerLockId != null) {
                    metaRowLock.releaseRowLock(brokerLockId);
                }
            }
        } catch (Throwable e) {
            return logExceptionInfo(e, printPrefix, strBuff, result);
        } finally {
            if (topicLockId != null) {
                metaRowLock.releaseRowLock(topicLockId);
            }
        }
        // print log to file
        if (result.isSuccess()) {
            logger.info(strBuff.append(printPrefix).append(operator)
                    .append(" deleted topic deploy configure: ")
                    .append(curEntity).toString());
            strBuff.delete(0, strBuff.length());
        }
        return result.isSuccess();
    }
Add or Update topic 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