提交 b3384d28 编写于 作者: H huzongtang

[issue#1164]Consumer Instance can't consume message from slave when the TPS of...

[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.
上级 929c76c6
...@@ -1864,6 +1864,7 @@ public class DefaultMessageStore implements MessageStore { ...@@ -1864,6 +1864,7 @@ public class DefaultMessageStore implements MessageStore {
this.reputFromOffset += size; this.reputFromOffset += size;
} else { } else {
doNext = false; doNext = false;
if (DefaultMessageStore.this.getMessageStoreConfig().isEnableDLegerCommitLog()) {
log.error("[BUG]dispatch message to consume queue error, COMMITLOG OFFSET: {}", log.error("[BUG]dispatch message to consume queue error, COMMITLOG OFFSET: {}",
this.reputFromOffset); this.reputFromOffset);
...@@ -1871,6 +1872,7 @@ public class DefaultMessageStore implements MessageStore { ...@@ -1871,6 +1872,7 @@ public class DefaultMessageStore implements MessageStore {
} }
} }
} }
}
} finally { } finally {
result.release(); result.release();
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册