隊列中如何保證消息不被重複消費？

首先，比如 RabbitMQ、RocketMQ、Kafka，都有可能會出現消息重複消費的問題，正常。因爲這問題通常不是 MQ 自己保證的，是由我們開發來保證的。挑一個 Kafka 來舉個例子，說說怎麼重複消費吧。 Kafka 實際上有個 offset 的概念，就是每個消息寫進去，都有一個 offset，代表消息的序號，然後 consumer 消費了數據之後，每隔一段時間（定時定期），會把自己消費過

>>阅读原文<<