(rocketmq) branch develop updated: [ISSUE #9654] Optimize the bufferLocal size of the TimerMessageStore (#9655)

[lizhimin]

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

lizhimins 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 89166af997 [ISSUE #9654] Optimize the bufferLocal size of the 
TimerMessageStore (#9655)
89166af997 is described below

commit 89166af9977c20a11f962271e1b2ad1a67e838ce
Author: ymwneu <ymw...@126.com>
AuthorDate: Mon Aug 3 11:24:22 2026 +0800

    [ISSUE #9654] Optimize the bufferLocal size of the TimerMessageStore (#9655)
---
 .../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
index 157f237f7b..24d2faa9b6 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -223,7 +223,10 @@ public class TimerMessageStore {
         bufferLocal = new ThreadLocal<ByteBuffer>() {
             @Override
             protected ByteBuffer initialValue() {
-                return 
ByteBuffer.allocateDirect(storeConfig.getMaxMessageSize() + 100);
+                int maxMessageBodySize = storeConfig.getMaxMessageSize();
+                int maxMessageSize = Integer.MAX_VALUE - maxMessageBodySize >= 
64 * 1024 ?
+                        maxMessageBodySize + 64 * 1024 : Integer.MAX_VALUE;
+                return ByteBuffer.allocateDirect(maxMessageSize);
             }
         };