Kafka实时API探秘 (kafka实现延迟队列)

事件被写入 Kafka 主题后，就可供一个或多个消费者读取。消费者可以采用传统的发布/订阅方式，并在新事件到达时接收它们，也可以根据应用程序的需要选择重新消费之前某个时间点的事件。Kafka 的这种回放功能要归功于它的持久和可伸缩的存储层，这给很多重要的实际应用场景提供了巨大优势，如机器学习和 A/B 测试，这些场景同时需要历史数据和实时数据。在受监管的行业中，数据必须保留多年才符合法律规定。传统的消息传递系统如 RabbitMQ、ActiveMQ 无法支持这样的要求。