This is an automated email from the ASF dual-hosted git repository. lizhimin pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push: new 5ca4dfe0a7 [ISSUE #9176] Fix pop message header missing fields when enable ACL 2.0 (#9179) 5ca4dfe0a7 is described below commit 5ca4dfe0a7b1b4d717636beaeebef66e5ebb8ff1 Author: zzl <87265072+zhilia...@users.noreply.github.com> AuthorDate: Fri Feb 21 14:17:03 2025 +0800 [ISSUE #9176] Fix pop message header missing fields when enable ACL 2.0 (#9179) --- .../java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java index 9355af319e..8e056920f7 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java @@ -234,6 +234,7 @@ public class PopMessageProcessor implements NettyRequestProcessor { final PopMessageRequestHeader requestHeader = request.decodeCommandCustomHeader(PopMessageRequestHeader.class, true); final PopMessageResponseHeader responseHeader = (PopMessageResponseHeader) response.readCustomHeader(); + requestHeader.setBornTime(System.currentTimeMillis()); // Pop mode only supports consumption in cluster load balancing mode brokerController.getConsumerManager().compensateBasicConsumerInfo(