使用RocketMQMessageListener订阅多个topic的问题

[MrZbb]

当在一个应用实例使用RocketMQMessageListener订阅多个topic,使用一个消费组的时候例如以下这样 1.@RocketMQMessageListener(topic = "test1",consumerGroup = "consumerGroup") 2.@RocketMQMessageListener(topic = "test2",consumerGroup = "consumerGroup") 会存在严重的消息丢失情况，去服务器查看topic跟的队列信息会出现以下情况，部分队列没有被client绑定造成消息丢失。 但是看了下官方文档的订阅关系原则如下，一个消费者组跟不同的topic的关系是独立的，这边的设计是否产生了矛盾

[zangxiyang]

老哥解决了吗？

[YshGitHubfcasd]

您可以通过实现RocketMQPushConsumerLifecycleListener并在prepareStart中为不同consumerGroup的RocketMQMessageListener设置唯一的instanceName来解决此问题。

[MrZbb]

老哥解决了吗？

最后一个应用实例针对不同topic用的不同consumer-group...只能这样了

[mufengCc]

你理解的有问题，代码中明显订阅关系不一致。官方文档：https://rocketmq.apache.org/zh/docs/4.x/bestPractice/07subscribe

[15521935616]

你理解的有问题，代码中明显订阅关系不一致。官方文档：https://rocketmq.apache.org/zh/docs/4.x/bestPractice/07subscribe

确实是订阅关系不一致的问题，那同一个consumer group下多个consumer同时订阅多个topic，老哥有解决思路吗

[mufengCc]

参考上图

[MrZbb]

参考上图

我这边理解从应用维度了（比如图中的c1是一个应用节点，而不是一个应用里的一个consumer对象），一个应用当一个消费者了。那如果以应用内的一个consumer对象看，那确实我这边理解错了，但是这样子写，会不会存在一个topic需要广播模式消费，一个topic是普通消费就不行了，这种配置方式就不行了