如果commitlog存储的时候,断电等异常场景导致的落盘数据是不完整的消息,等故障后重新启动Roc

如果commitlog存储的时候,断电等异常场景导致的落盘数据是不完整的消息,等故障后重新启动RocketMQ目前是如何处理最后的这条不完整消息? 老师能简述下吗,目前来不及看这块源码了

展开
收起
游客3oewgrzrf6o5c 2022-08-09 10:16:10 270 分享 版权
1 条回答
写回答
取消 提交回答
  • 简单说吧,在不考虑HA的情况下,1.如果是同步刷盘,消息没有落盘的情况下,客户端会报错。 2如果是异步刷盘,分两种情况,1)commitlog已落盘,cq可以恢复,消息正常,2)如果commitlog没有刷成功,这条消息丢失。 如果用在高可靠场景,可以调整正同步刷盘。(此答案整理自群2-Apache RocketMQ 中国开发者钉钉群)

    2022-08-09 10:23:21
    赞同 展开评论
问答分类:
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

收录在圈子:
+ 订阅
阿里云 云原生应用平台 肩负阿里巴巴集团基础设施云化以及核心技术互联网化的重要职责,致力于打造稳定、标准、先进的云原生产品,成为云原生时代的引领者,推动行业全面想云原生的技术升级,成为阿里云新增长引擎。商业化产品包括容器、云原生中间件、函数计算等。
还有其他疑问?
咨询AI助理