@Override
    @Transactional(rollbackFor = Throwable.class, isolation = Isolation.REPEATABLE_READ)
    public void updateOpt(InlongConsumeRequest request, String operator) {
        // firstly check the topic info
        if (StringUtils.isNotBlank(request.getTopic())) {
            this.checkTopicInfo(request);
        }
        // get the entity from request
        InlongConsumeEntity entity = consumeMapper.selectById(request.getId());
        // set the ext params
        this.setTargetEntity(request, entity);
        entity.setModifier(operator);

        int rowCount = consumeMapper.updateByIdSelective(entity);
        if (rowCount != InlongConstants.AFFECTED_ONE_ROW) {
            LOGGER.error("inlong consume has already updated with id={}, expire version={}",
                    request.getId(), request.getVersion());
            throw new BusinessException(ErrorCodeEnum.CONFIG_EXPIRED);
        }
    }
Set the parameters of the target entity.

@param request inlong consume request
@param targetEntity targetEntity which will set the new parameters
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/consume/AbstractConsumeOperator.java