一、消息发送
1、ack=0，不重试
producer发送消息完，不管结果了，如果发送失败也就丢失了。
2、ack=1，leader crash
producer发送消息完，只等待 leader 写入成功就返回了，leader crash了，这时follower没来及同步，消息丢失，
3、unclean .leader .election .enable 配置true
允许选举ISR以外的副本作为leader,会导致数据丢失，默认为false。producer发送异步消息完，只等待leader 写入成功就返回了，leader crash了，这时ISR中没有follower，leader从OSR中选举，因为OSR中本来落后于Leader造成消息丢失。
解决方案:
1、配置: ack=all / -1,tries > 1,unclean.leader.election.enable : false
producer发送消息完，等待follower同步完再返回，如果异常则重试。副本的数量可能影响吞吐量。
不允许选举ISR以外的副本作为leader文章来源：https://www.toymoban.com/news/detail-599849.html
2、配置: min.insync.replicas >文章来源地址https://www.toymoban.com/news/detail-599849.html
到了这里，关于94、Kafka消息丢失的场景及解决方案的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
