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

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

>>阅读原文<<