lizhimins commented on code in PR #9142:
URL: https://github.com/apache/rocketmq/pull/9142#discussion_r1921986158
##########
store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java:
##########
@@ -472,6 +472,20 @@ public void setRocksdbCompressionType(String
compressionType) {
**/
private boolean useABSLock = false;
+ /**
+ * Maximum number of messages to be read each time
+ * -1 : read all messages
+ */
+ private int readCountTimerOnRocksDB = -1;
+
+ /**
+ * When enabled, the scheduled task is started.
+ * if time wheel is enabled, the time wheel only the correct ones are
supported
+ * The message will be written to rocksdb.
+ * Close the time wheel when the file timing message is 0
+ */
+ private boolean enableTimerMessageOnRocksDB = false;
Review Comment:
init 开关和 enable 开关分离，init 表示服务是否初始化，enable 来切换
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
