commit 2569041b4250e83837b002f6d6bcc149caea3b01
author guyinyou <36399867+guyinyou@users.noreply.github.com> Wed Jul 06 14:16:59 2022 +0800
committer GitHub <noreply@github.com> Wed Jul 06 14:16:59 2022 +0800
tree cf16569cad21adaf0322271637e93151b501925a
parent 001dfa88ac57c3e57be7bbe10ec8c7859696cad2

Fix autoBatch not compatible with batchConsumeQueue (#4563)

client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java

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
index 6c5ea85..5006311 100644
--- 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 @@
             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;
         }