Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
ldcsaa opened this issue Aug 16, 2024 · 0 comments

Comments

@ldcsaa
Copy link

ldcsaa commented Aug 16, 2024

现象: 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 的重试消息
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant