如何保證消息隊列消息不被重複消費/冪等性

RabbitMQ、RocketMQ、Kafka等消息隊列如果不做任何的防護措施都是有可能出現消息重複消費的情況的。保證消息的不可重複消費一般都是需要開發人員來進行相對於的設置。 Kafka 實際上有個 offset 的概念，每個寫入的消息都會有一個 offset ，代表的是消息的序號，在 consumer 消費之後，每隔一段時間（定時定期），都會將自己消費過的 offset 進行提交，標識一下哪些

>>阅读原文<<