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

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