Pulsar 是一个分布式消息平台，设计上将消息路由与存储分开，提供独占、共享、主备和按键共享四种订阅语义，适应不同场景。消费者通过 ack 机制确认消息处理，支持累积确认和事务性确认。Pulsar 的 cursor 机制确保消费者掉队时消息不丢失，允许不同消费速度的订阅互不干扰。这些设计使 Pulsar 在灵活性和控制上优于其他消息中间件。

Kafka 4.0引入KIP-932，增加了队列语义，允许逐条确认消息，适用于作业排队等场景。多个消费者可以处理同一分区的消息，提高了并行处理能力。尽管当前版本缺乏死信队列支持和重试时间控制，但为用户提供了简单的排队解决方案，未来版本有望改进。

本文介绍了AckQueue的实现，该内存队列在消息消费成功后才移除消息，并支持定时将未确认的消息重新入队。示例代码展示了AckQueue的入队、出队和确认操作。