[rocketmq] branch 5.0.0-beta-auto-batch updated: Fix autoBatch not compatible with batchConsumeQueue (#4563)

[du...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch 5.0.0-beta-auto-batch
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-beta-auto-batch by this push:
     new 2569041b4 Fix autoBatch not compatible with batchConsumeQueue (#4563)
2569041b4 is described below

commit 2569041b4250e83837b002f6d6bcc149caea3b01
Author: guyinyou <36...@users.noreply.github.com>
AuthorDate: Wed Jul 6 14:16:59 2022 +0800

    Fix autoBatch not compatible with batchConsumeQueue (#4563)
---
 .../java/org/apache/rocketmq/client/producer/ProduceAccumulator.java    | 2 ++
 1 file changed, 2 insertions(+)

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 6c5ea8531..500631186 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.client.log.ClientLogger;
 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 @@ public class ProduceAccumulator {
             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;
         }