kafka：如何保证消息不丢失不重复

首先要考虑这么几个问题： 消息丢失是什么形成的？（从生产端和消费端两个角度来考虑）缓存 消息重复是什么形成的？（从生产端和消费端两个角度来考虑）安全 如何保证消息有序？网络 若是保证消息不重不漏，损失的是什么？异步   下面是文章详情，这里先简单总结一下： 消费端重复消费：很容易解决，创建去重表。async 消费端丢失数据：也容易解决，关闭自动提交offset，处理完以后受到移位。函数 生产端重复

>>阅读原文<<