YAGAMIL opened a new issue #2339:
URL: https://github.com/apache/rocketmq/issues/2339


   我的一个spring-boot应用需要消费两个topic,其中一个需要广播,另一个topic则负载均衡即可,如图所示。
   
![image](https://user-images.githubusercontent.com/16757285/95534639-ef95d900-0a18-11eb-9a44-dcff8971e540.png)
   我有三个消费者组,每一个消费者组都对应一个单独的topic,分别如下
   DemoMqListener:
   
![image](https://user-images.githubusercontent.com/16757285/95534704-118f5b80-0a19-11eb-8496-fe9b8bd51e72.png)
   Topic4SingleMeddleConsumerTopic4SingleMeddleConsumer:
   
![image](https://user-images.githubusercontent.com/16757285/95534740-2c61d000-0a19-11eb-91f1-e89f5f948ff4.png)
   
   Topic4SingleRunConsumer
   
![image](https://user-images.githubusercontent.com/16757285/95534790-4bf8f880-0a19-11eb-941b-ac16a4071716.png)
   
   但是当消息发送成功后,该springboot应用并不能主动消费消息,而在rocketMQ的控制台中,则可以看到
   
![image](https://user-images.githubusercontent.com/16757285/95534877-8ebad080-0a19-11eb-9ba2-972402025935.png)
   点开消息详情后,我可以通过点击“resend 
Message”来手动消费,这样的话我的springboot应用就可以消费到该消息,但还有一点奇怪的是,名称为“consumer-group”的消费者组是我的测试消费,它只订阅了test-topic,但它却可以消费到topic-task:all-single这条topic的信息,如果同样混乱,但TASK_MEDDLE_CONSUMER_GROUP_NAME的消费者组却不能消费到topic-task的信息,这让我很迷惑,而且我的所有应用都没有接收到消息,但控制台已经提示应该resend了,但我手动点击resend的时候,我的应用才真正接收到了消息
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to