From b3384d289e12641db1628c03b40f7cc714fc99fd Mon Sep 17 00:00:00 2001 From: huzongtang Date: Sat, 27 Apr 2019 11:49:02 +0800 Subject: [PATCH] [issue#1164]Consumer Instance can't consume message from slave when the TPS of cluster is in the high level and master has been killed. --- .../org/apache/rocketmq/store/DefaultMessageStore.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) 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 6cec58d8..70efabf1 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; + } } } } -- GitLab