如何保證消息不被重複消費?(如何保證消息消費時的冪等性)

首先就是比如rabbitmq、rocketmq、kafka，都有可能會出現消費重複消費的問題，正常。因爲這問題通常不是mq自己保證的，是給你保證的。然後我們挑一個kafka來舉個例子，說說怎麼重複消費吧。   kafka實際上有個offset的概念，就是每個消息寫進去，都有一個offset，代表他的序號，然後consumer消費了數據之後，每隔一段時間，會把自己消費過的消息的offset提交一下，

>>阅读原文<<