JosephChanChan opened a new issue, #5235: URL: https://github.com/apache/rocketmq/issues/5235
There a problem when mapfile flush message to disk. details see: https://github.com/apache/rocketmq/issues/3129 The measures bellow: - message property: MessageConst.PROPERTY_WAIT_STORE_MSG_OK to true - broker config : flushDiskType=FlushDiskType.SYNC_FLUSH It can't ensure a message could be flush to disk. the flushedPosition would updated to writePosition even if a error was occurred. then return a PUT_OK result to producer in GroupCommitService.doCommit function <img width="1127" alt="image" src="https://user-images.githubusercontent.com/19208259/193216122-dd6d80dd-598e-4e16-ad2a-043b4985708c.png";> there some messages will be lost if power off now, and the producer has been received a ok response. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
![https://user-images.githubusercontent.com/19208259/193216122-dd6d80dd-598e-4e16-ad2a-043b4985708c.png"](https://user-images.githubusercontent.com/19208259/193216122-dd6d80dd-598e-4e16-ad2a-043b4985708c.png"){kind=link}