目录

生产者消息确认机制

Kafka 生产者 ACK 机制

RocketMQ 生产者确认机制

消费者消息确认机制

Kafka 消费者确认机制

RocketMQ 消费者确认机制

核心差异对比

选型建议

---

消息确认机制是分布式消息中间件的核心功能之一，它直接关系到消息传递的可靠性和系统性能。下面我将从生产者和消费者两个角度，详细对比 Kafka 和 RocketMQ 的消息确认机制。

生产者消息确认机制

Kafka 生产者 ACK 机制

Kafka 提供了三种级别的生产者确认机制（ACK 机制），通过 acks 参数配置：

ACK 级别	描述	可靠性	性能	适用场景
acks=0	生产者发送消息后不等待任何确认	最低	最高	日志采集等对可靠性要求不高的场景
acks=1	等待 Leader 副本写入本地日志后返回确认	中等	中等	实时监控等对可靠性和性能都有一定要求的场景
acks=-1 (或 all)	等待 ISR 中所有副本都写入日志后返回确认	最高	最低	金融交易等对可靠性要求极高的场景

Kafka 的 ACK 机制还受到 ISR（In-Sync Replicas，同步副本集合）的影响。ISR 是与 Leader 保持同步的 Follower 副本集合，当 Leader 故障时会从 ISR 中选举新的 Leader‌。

RocketMQ 生产者确认机制

RocketMQ 提供了三种消息发送方式，对应不同的确认机制：

1. ‌同步发送‌：

   • 生产者发送消息后阻塞等待 Broker 返回 SendResult
   • 包含消息状态（SEND_OK、FLUSH_DISK_TIMEOUT 等）
   • 默认重试 2 次（可通过 retryTimesWhenSendFailed 配置）
   • 可靠性最高，但性能较低‌

2. ‌异步发送‌：

   • 通过回调函数 SendCallback 处理成功或异常
   • 性能介于同步和单向发送之间
   • 需要处理回调逻辑‌

3. ‌单向发送‌：

   • 不关心发送结果，无确认机制
   • 性能最高，但可靠性最低
   • 适用于日志收集等场景‌

消费者消息确认机制

Kafka 消费者确认机制

Kafka 的消费者确认是通过‌位移（offset）提交‌实现的：

1. 消费者为每个分区维护自己的消费位移（offset）
2. 消费者需要显式提交 offset 以确认消息已成功处理
3. 提交方式：
   • ‌自动提交‌：定期自动提交（可能重复消费）
   • ‌手动提交‌：
     • 同步提交：commitSync()
     • 异步提交：commitAsync()
4. 如果消费者崩溃，将从最后提交的 offset 处重新消费‌

RocketMQ 消费者确认机制

RocketMQ 的消费者确认机制更为显式：

1. 消费者通过回调函数返回状态确认消息：

   • ConsumeConcurrentlyStatus.CONSUME_SUCCESS：确认消费成功
   • ConsumeConcurrentlyStatus.RECONSUME_LATER：消费失败，需要重试

2. ‌重试机制‌：

   • 失败的消息会被发送到 RETRY topic
   • 默认重试 16 次，间隔可配置
   • 超过最大重试次数后进入死信队列（DLQ）

3. ‌顺序消费‌：

   • 顺序消费回调不返回 RECONSUME_LATER
   • 而是暂停队列等待消息重试成功‌

核心差异对比

特性	Kafka	RocketMQ
‌生产者确认‌	通过 acks 参数配置级别（0/1/all）	通过发送方式决定（同步/异步/单向）
‌消费者确认‌	通过 offset 提交实现	通过显式返回消费状态实现
‌重试机制‌	依赖消费者重新消费	内置重试队列和死信队列
‌顺序保证‌	分区内有序	队列内有序，且提供严格顺序消费模式
‌设计侧重‌	高吞吐量	金融级可靠性

选型建议

• ‌选择 Kafka‌ 如果：

  • 需要极高的吞吐量
  • 可以接受一定程度的消息延迟
  • 系统已有 Kafka 技术栈

• ‌选择 RocketMQ‌ 如果：

  • 需要金融级可靠性保证
  • 需要灵活的重试和死信处理
  • 业务场景涉及事务消息

两者在消息确认机制上的差异反映了它们不同的设计哲学：Kafka 更注重吞吐量和水平扩展，而 RocketMQ 更注重消息的可靠传递和事务支持。