@Override
    public ProcessEvent event() {
        return ProcessEvent.REJECT;
    }
Inlong consume process rejection event listener
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/consume/apply/RejectConsumeProcessListener.java