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 {