【九】kafka延遲隊列、重試隊列、死信隊列

一、延遲隊列 實現方案： 在發送延時消息的時候並不是先投遞到要發送的真實主題（real_topic）中，而是先投遞到一些 Kafka 內部的主題（delay_topic）中，這些內部主題對用戶不可見， 然後通過一個自定義的服務拉取這些內部主題中的消息，並將滿足條件的消息再投遞到要發送的真實的主題中，消費者所訂閱的還是真實的主題。 如果採用這種方案，那麼一般是按照不同的延時等級來劃分的，比如設定5s

>>阅读原文<<