[ISSUE apache#8835] When ck is in the buffer, incomplete ack will lea…

…d to message duplication. (apache#8836) * add brokerName in ackMsg * add brokerName in ackMsg
luozongle01 · Oct 17, 2024 · 031687d · 031687d
1 parent 4f5f705
commit 031687d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
@@ -644,6 +644,7 @@ private void putAckToStore(final PopCheckPointWrapper pointWrapper, byte msgInde
         ackMsg.setTopic(point.getTopic());
         ackMsg.setQueueId(point.getQueueId());
         ackMsg.setPopTime(point.getPopTime());
+        ackMsg.setBrokerName(point.getBrokerName());
         msgInner.setTopic(popMessageProcessor.reviveTopic);
         msgInner.setBody(JSON.toJSONString(ackMsg).getBytes(DataConverter.CHARSET_UTF8));
         msgInner.setQueueId(pointWrapper.getReviveQueueId());