This is an automated email from the ASF dual-hosted git repository.
lollipop 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 5936695b38 Revert "[ISSUE #9176] Fix pop message header missing fields
when enable ACL 2…" (#9211)
5936695b38 is described below
commit 5936695b384d457ed9b6b17ad135a148e11e562a
Author: lizhimins <[email protected]>
AuthorDate: Fri Feb 28 09:52:46 2025 +0800
Revert "[ISSUE #9176] Fix pop message header missing fields when enable ACL
2…" (#9211)
This reverts commit 5ca4dfe0a7b1b4d717636beaeebef66e5ebb8ff1.
---
.../java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java | 1 -
1 file changed, 1 deletion(-)
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 8e056920f7..9355af319e 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,7 +234,6 @@ 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(
