@Override
    public ListenerResult listen(WorkflowContext context) throws WorkflowListenerException {
        ApplyConsumeProcessForm consumeForm = (ApplyConsumeProcessForm) context.getProcessForm();
        ConsumeApproveForm approveForm = (ConsumeApproveForm) context.getActionContext().getForm();
        InlongConsumeInfo consumeInfo = consumeForm.getConsumeInfo();
        if (StringUtils.equals(approveForm.getConsumerGroup(), consumeInfo.getConsumerGroup())) {
            return ListenerResult.success("Consumer group has not been modified");
        }

        boolean exist = consumeService.consumerGroupExists(approveForm.getConsumerGroup(), consumeInfo.getId());
        if (exist) {
            log.error("consumer group {} already exist", approveForm.getConsumerGroup());
            throw new BusinessException(ErrorCodeEnum.CONSUMER_GROUP_DUPLICATED);
        }
        return ListenerResult.success(String.format("Consumer group %s change to %s",
                consumeInfo.getConsumerGroup(), approveForm.getConsumerGroup()));
    }
New inlong consume approval task event listener
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/consume/OperateConsumeTaskListener.java