diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java
index 3b2209073..11dea87d5 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEventListener.java
@@ -145,7 +145,7 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord
         eventProducer.send(Event.builder()
                 .shardingKey(dto.getProcessInstanceId())
                 .eventCode(eventEnum.getEventCode())
-                .targetId(dto.getProcessTaskId())
+                .targetId(dto.getProcessInstanceId())
                 .targetType(eventEnum.getTag())
                 .data(dto)
                 .build());