消息中间件（四）之-kafka重复消费问题

其实kafka的重复消费问题究其底层根本原因就是：已经消费了数据，但是offset没提交(kafka没有或者不知道该数据已经被消费)。 基于这种原因总结以下几个易造成重复消费的配置： 原因1：强行kill线程，导致消费后的数据，offset没有提交（消费系统宕机、重启等）。  原因2：设置offset为自动提交，关闭kafka时，如果在close之前，调用 consumer.unsubscribe

>>阅读原文<<