diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
index 2057c81..db29ea5 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
@@ -13,6 +13,7 @@ import com.njcn.redis.utils.RedisUtil;
 import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.ConsumeMode;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Service;
@@ -30,8 +31,9 @@ import java.util.Objects;
 @Service
 @RocketMQMessageListener(
         topic = BusinessTopic.REPLY_TOPIC,
-        consumerGroup = BusinessTopic.REPLY_TOPIC,
+        consumerGroup = "RECALL",
         selectorExpression = "RECALL",
+        consumeMode = ConsumeMode.ORDERLY,
         consumeThreadNumber = 10,
         enableMsgTrace = true
 )
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
index d7ded6d..25d28ef 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
@@ -12,6 +12,7 @@ import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import com.njcn.zlevent.api.EventFeignClient;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.ConsumeMode;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Service;
@@ -31,6 +32,7 @@ import java.util.Objects;
         topic = BusinessTopic.LOG_TOPIC,
         consumerGroup = BusinessTopic.LOG_TOPIC,
         consumeThreadNumber = 10,
+        consumeMode = ConsumeMode.ORDERLY,
         enableMsgTrace = true
 )
 @Slf4j
diff --git a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
index 2ea56d6..fe2578b 100644
--- a/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
+++ b/iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
@@ -14,6 +14,7 @@ import com.njcn.redis.utils.RedisUtil;
 import com.njcn.system.api.RocketMqLogFeignClient;
 import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.ConsumeMode;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Service;
@@ -32,8 +33,9 @@ import java.util.Objects;
 @Service
 @RocketMQMessageListener(
         topic = BusinessTopic.REPLY_TOPIC,
-        consumerGroup = BusinessTopic.REPLY_TOPIC,
+        consumerGroup = "LEDGER",
         selectorExpression = "LEDGER",
+        consumeMode = ConsumeMode.ORDERLY,
         consumeThreadNumber = 10,
         enableMsgTrace = true
 )