CS-Notes 学习笔记
面试最常问Java 后端 · 分布式与消息队列

怎样保证消息不丢失?

先自己想一想,再看参考要点

参考要点

  • 发送端:等待确认并重试(Kafka 用 acks=all,检查回调,退出前 flush),要与业务一致时用本地消息表或事务消息
  • 存储端:持久化加多副本(min.insync.replicas,不允许落后副本当选 Leader)
  • 消费端:处理完再提交偏移量或 ack
  • 关键业务再定期对账补发
在学习站中自测这道题看这道题所在的一天

学习站:先用面试题自评定级,按水平和面试日期排出每天的计划,自评过的题按间隔复习。免费、无需注册,记录只保存在自己的浏览器中。