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