diff --git a/docs/cn/best_practice.md b/docs/cn/best_practice.md index 39febbcddba2e2a722e30761591a3bc03f58f8a4..e4b04e0d564c4d4b8c0d494df3c1a707f6de57a4 100755 --- a/docs/cn/best_practice.md +++ b/docs/cn/best_practice.md @@ -289,7 +289,6 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul | offsetStore | | 消费进度存储 | | consumeThreadMin | 10 | 消费线程池最小线程数 | | consumeThreadMax | 20 | 消费线程池最大线程数 | -| | | | | consumeConcurrentlyMaxSpan | 2000 | 单队列并行消费允许的最大跨度 | | pullThresholdForQueue | 1000 | 拉消息本地队列缓存消息最大数 | | pullInterval | 0 | 拉消息间隔,由于是长轮询,所以为0,但是如果应用为了流控,也可以设置大于0的值,单位毫秒 | diff --git a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java index 17be11b1c3a847003e8d5bfb8b57a28c467880e5..5192e86defba1da4f0bb91080afec8fb3af5424c 100644 --- a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java @@ -99,12 +99,7 @@ public class DLedgerCommitLog extends CommitLog { @Override public boolean load() { - boolean result = super.load(); - if (!result) { - return false; - } - - return true; + return super.load(); } private void refreshConfig() {