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 b4ff736e2e7..73aaa69e74a 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 @@ private synchronized RemotingCommand switchTimerEngine(ChannelHandlerContext ctx 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 {