apache / apache/rocketmq-spring

【Bug】rocketmq-v5-client-spring-boot 的 Simple Consumer 是否不支持 FIFO 消息语义?

Open
#675 1 comment 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
2.3k
Forks
943
PR merge metrics
No merged PRs in 30d

Description

**现象:** _Simple Consumer 消费FIFO队列时,未对前一条消息执行确认(ack)的情形下,可以接收并确认下一条消息。_
这似乎违反了FIFO语义,请问是否为Bug。

操作步骤:
1. Simple Consumer 工作线程循环调用 `receive()` 方法接收FIFO队列消息
2. Producer 向 Simple Consumer 发送 FIFO 消息 A
3. Simple Consumer 接收到消息 A 后不确认(不调用 `ack()`)
4. Producer 向 Simple Consumer 发送 FIFO 消息 B
5. Simple Consumer 会收到 FIFO 消息 B
6. Simple Consumer 确认消息B(`ack(B)`)成功
7. 过一段时间后,Simple Consumer 会收到消息 A 的重试消息

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.