Kafka重复消费和丢失数据研究 Kafka重复消费原因 底层根本原因:已经消费了数据,但是offset没提交。 原因1:强行kill线程,导致消费后的数据,offset没有提交。 原因2:设置offset为自动提交,关闭kafka时,如果在close之前,调用consumer.unsubscribe() 则有可能部分offset没提交,下次重... 大数据 2023-08-23 52 点赞 0 评论 78 浏览