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 a6be1eec70 [ISSUE # 10086] Fix timer engine switch to persist correct 
config key (#10085)
a6be1eec70 is described below

commit a6be1eec70941e16d3b1e19df306583da167d783
Author: liuzhenyu <[email protected]>
AuthorDate: Wed Feb 11 14:14:15 2026 +0800

    [ISSUE # 10086] Fix timer engine switch to persist correct config key 
(#10085)
---
 .../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index b4ff736e2e..73aaa69e74 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -3466,13 +3466,13 @@ public class AdminBrokerProcessor implements 
NettyRequestProcessor {
             if (MessageConst.TIMER_ENGINE_ROCKSDB_TIMELINE.equals(engineType)) 
{
                 if (this.brokerController.getTimerMessageRocksDBStore() == 
null) {
                     response.setCode(ResponseCode.INVALID_PARAMETER);
-                    response.setRemark("timerUseRocksDB muse be configured 
true when broker start");
+                    response.setRemark("timerRocksDBEnable must be configured 
true when broker start");
                     return response;
                 }
                 result = 
this.brokerController.getTimerMessageRocksDBStore().restart();
                 if (result) {
                     properties.put("timerStopEnqueue", 
Boolean.TRUE.toString());
-                    properties.put("timerUseRocksDB", Boolean.TRUE.toString());
+                    properties.put("timerRocksDBEnable", 
Boolean.TRUE.toString());
                     properties.put("timerRocksDBStopScan", 
Boolean.FALSE.toString());
                 }
             } else {

Reply via email to