kmq:基于Kafka的消息队列 源码

Kafka消息队列 使用kmq您可以在Kafka中确认对单个消息的处理,并且可以在超时后重新发送未确认的消息。 这与通常的Kafka偏移量提交机制相反,在该机制下,您只能确认直到给定偏移量的所有消息。 如果您熟悉 ,则kmq实现类似的消息处理模型。 这是如何运作的? 有关更深入的概述,请参见博客:,以及性能基准: 确认机制使用marker主题,该marker主题的分区数应与“主要”数据主题(称为queue主题)相同。 标记主题用于通过为每个消息编写开始/结束标记来跟踪已处理的消息。 使用kmq 使用kmq的应用程序应包含以下组件: 一些RedeliveryTracker 。 该组