面试最常问Java 后端 · 分布式与消息队列 怎样保证消息不丢失? 先自己想一想,再看参考要点参考要点发送端:等待确认并重试(Kafka 用 acks=all,检查回调,退出前 flush),要与业务一致时用本地消息表或事务消息存储端:持久化加多副本(min.insync.replicas,不允许落后副本当选 Leader)消费端:处理完再提交偏移量或 ack关键业务再定期对账补发消息队列的可靠性