Fix autoBatch not compatible with batchConsumeQueue (#4563)

apache · Jul 6, 2022 · 2569041 · 2569041
1 parent 001dfa8
commit 2569041
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java b/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
@@ -35,6 +35,7 @@
 import org.apache.rocketmq.common.ServiceThread;
 import org.apache.rocketmq.common.message.Message;
 import org.apache.rocketmq.common.message.MessageBatch;
+import org.apache.rocketmq.common.message.MessageClientIDSetter;
 import org.apache.rocketmq.common.message.MessageConst;
 import org.apache.rocketmq.common.message.MessageDecoder;
 import org.apache.rocketmq.common.message.MessageQueue;
@@ -409,6 +410,7 @@ private MessageBatch batch() {
             messageBatch.setWaitStoreMsgOK(this.aggregateKey.waitStoreMsgOK);
             messageBatch.setKeys(this.keys);
             messageBatch.setTags(this.aggregateKey.tag);
+            MessageClientIDSetter.setUniqID(messageBatch);
             messageBatch.setBody(MessageDecoder.encodeMessages(this.messages));
             return messageBatch;
         }