diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 6cec58d861637826856f04324325646eccc3d14f..70efabf1021fbcf23aa6af0523dbc4e537f920cd 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -1864,10 +1864,12 @@ public class DefaultMessageStore implements MessageStore { this.reputFromOffset += size; } else { doNext = false; - log.error("[BUG]dispatch message to consume queue error, COMMITLOG OFFSET: {}", - this.reputFromOffset); + if (DefaultMessageStore.this.getMessageStoreConfig().isEnableDLegerCommitLog()) { + log.error("[BUG]dispatch message to consume queue error, COMMITLOG OFFSET: {}", + this.reputFromOffset); - this.reputFromOffset += result.getSize() - readSize; + this.reputFromOffset += result.getSize() - readSize; + } } } }