Kafka如何保证消息不丢

Kafka 的“消息不丢”不是一个配置能解决的而是要在生产者 → Broker → 消费者三个环节同时做保证。下面从“为什么会丢”到“怎么解决”做一次完整拆解。一、先明确Kafka 消息丢失发生在哪几层一条消息的生命周期Producer 发送 → Broker 存储/复制 → Consumer 拉取 → Consumer 提交 offset所以丢失可能发生在生产者端发送失败、确认策略太弱、缓冲丢失、重试不合理Broker 端副本数不足、ISR 门槛太低、unclean leader 选举、刷盘策略消费者端offset 提前提交、自动提交、rebalance 时处理不当端到端语义重复消费、消费逻辑非幂等、事务缺失