diff --git a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
index 64564de8..d5fd9be0 100644
--- a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
+++ b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
@@ -71,6 +71,7 @@ public class RocketMQEventConfiguration {
     @RocketMQMessageListener(topic = "topic_thrones_${spring.profiles.active}",
             consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
+            consumeMode = ConsumeMode.ORDERLY,
             nameServer = "${rocketmq.name-server}"
     )
     public static class ThronesListener extends BaseListener implements RocketMQListener<MessageExt> {
@@ -113,6 +114,7 @@ public class RocketMQEventConfiguration {
     @RocketMQMessageListener(topic = "topic_tyr_${spring.profiles.active}",
             consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
+            consumeMode = ConsumeMode.ORDERLY,
             nameServer = "${rocketmq.name-server}"
     )
     public static class TyrListener extends BaseListener implements RocketMQListener<MessageExt> {
@@ -155,6 +157,7 @@ public class RocketMQEventConfiguration {
     @RocketMQMessageListener(topic = "topic_apisix_plat_${spring.profiles.active}",
             consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
+            consumeMode = ConsumeMode.ORDERLY,
             nameServer = "${rocketmq.name-server}"
     )
     public static class ApiSixPlatListener extends BaseListener implements RocketMQListener<MessageExt> {