apache / apache/rocketmq-spring
使用RocketMQMessageListener订阅多个topic的问题
Open
- Dominant language
- Java
- Stars
- 2.3k
- Forks
- 943
- PR merge metrics
- No merged PRs in 30d
Description
当在一个应用实例使用RocketMQMessageListener订阅多个topic,使用一个消费组的时候例如以下这样
1.@RocketMQMessageListener(topic = "test1",consumerGroup = "consumerGroup")
2.@RocketMQMessageListener(topic = "test2",consumerGroup = "consumerGroup")
会存在严重的消息丢失情况,去服务器查看topic跟的队列信息会出现以下情况,部分队列没有被client绑定造成消息丢失。

但是看了下官方文档的订阅关系原则如下,一个消费者组跟不同的topic的关系是独立的,这边的设计是否产生了矛盾

Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.