高大皮卡丘

文章
6
资源
0
加入时间
3年0月21天

Kafka重复消费和丢失数据研究

Kafka重复消费原因 底层根本原因:已经消费了数据,但是offset没提交。 原因1:强行kill线程,导致消费后的数据,offset没有提交。 原因2:设置offset为自动提交,关闭kafka时,如果在close之前,调用consumer.unsubscribe() 则有可能部分offset没提交,下次重...