diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
index 84341e425..648708463 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java
@@ -170,7 +170,7 @@ public class RocketMqBpmActivityEventListener implements BpmnActivityEventListen
             return;
         }
         eventProducer.send(Event.builder()
-                .shardingKey(dto.getActivityId())
+                .shardingKey(dto.getProcessInstanceId())
                 .eventCode(eventEnum.getEventCode())
                 .targetId(dto.getActivityId())
                 .targetType(eventEnum.getTag())
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 b0a5af339..c510e1777 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
@@ -134,7 +134,7 @@ public class RocketMqBpmnTaskEventListener implements BpmnTaskEventListener, Ord
             return;
         }
         eventProducer.send(Event.builder()
-                .shardingKey(dto.getProcessTaskId())
+                .shardingKey(dto.getProcessInstanceId())
                 .eventCode(eventEnum.getEventCode())
                 .targetId(dto.getProcessTaskId())
                 .targetType(eventEnum.getTag())