【九】kafka延迟队列、重试队列、死信队列

一、延迟队列 实现方案： 在发送延时消息的时候并不是先投递到要发送的真实主题（real_topic）中，而是先投递到一些 Kafka 内部的主题（delay_topic）中，这些内部主题对用户不可见， 然后通过一个自定义的服务拉取这些内部主题中的消息，并将满足条件的消息再投递到要发送的真实的主题中，消费者所订阅的还是真实的主题。 如果采用这种方案，那么一般是按照不同的延时等级来划分的，比如设定5s

>>阅读原文<<