saharaheart opened a new issue #2830: URL: https://github.com/apache/rocketmq/issues/2830
Hello everyone! When reading the source code about consumerQueue, I found thet the reputMessageService relies on the commitLog.getMaxOffset() to append message to consumer queue. However, the value of commitLog.getMaxOffset() may just change before the message actually been flushed to the disk or replicated by the slave. So will that be possible that the consumer will see the message that has not been flushed and duplicated by the slave? I checked that the logic of ha service and handleDiskFlush happened after changing the commitLog' maxOffset and the reputMessage service is concurrent with those logics. Did I miss something? -- 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. For queries about this service, please contact Infrastructure at: [email protected]
