apache / apache/rocketmq-spring

使用RocketMQMessageListener订阅多个topic的问题

Open
#556 13 comments 4 reactions 0 assignees View on GitHub
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绑定造成消息丢失。
![image](https://user-images.githubusercontent.com/31841743/234159423-ca3e3ad0-7de5-4970-9241-9f5fb9bb6ec8.png)
但是看了下官方文档的订阅关系原则如下,一个消费者组跟不同的topic的关系是独立的,这边的设计是否产生了矛盾
![image](https://user-images.githubusercontent.com/31841743/234159683-23274d85-1a51-497e-b243-aeca645d1452.png)

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.