You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/02/11 07:04:05 UTC

[GitHub] [rocketmq] dujinsong removed a comment on issue #2653: RocketMQ messages are sent to two nodes in the cluster. What is the reason that the consumer can only consume data on one node?

dujinsong removed a comment on issue #2653:
URL: https://github.com/apache/rocketmq/issues/2653#issuecomment-1035930601


   > > > > instanceName
   > > > 
   > > > 
   > > > > > > > 只有在广播模式的时候可以连上broker2,集群模式的时候只能消费broker1上的消息
   > > > > > > 
   > > > > > > 
   > > > > > > 消费者只启动了单台吗?是以容器的方式启动的吗?
   > > > > > 
   > > > > > 
   > > > > > 用的是docker容器启动的集群
   > > > > 
   > > > > 
   > > > > 是同一台机器上有多个docker容器吗?是不是instanceName相同导致的,可以consumer强制setInstanceName,保证每一个consumer的instanceName都独一无二试试
   > > > 
   > > > 
   > > > 是通过docker-compose搭建的单机集群,集群架构是2nameServer+2master+2salve
   > > > 这个是docker-compose的配置文件
   > > > [docker-compose.txt](https://github.com/apache/rocketmq/files/6002156/docker-compose.txt)
   > 
   > 设置强制消费也测试过,不起作用
   
   哈喽,我遇到过此情况,不知道能否解决你的问题。先启动一个broker集群,正常收发消息,后面扩容了一个broker集群,扩容的集群能发送消息,但是没有消费,我通过console将topic以及哈喽,我遇到过此情况,不知道能否解决你的问题。先启动一个broker集群,正常收发消息,后面扩容了一个broker集群,扩容的集群能发送消息,但是没有消费,我通过console将topic以及消费组添加到新集群中后能够消费消息。扩容broker集群提前将plain_acl.yml、topics.json 以及subscriptionGroup.json文件拷贝到新集群的相应目录下能够避免此问题。消费组添加到新集群中后能够消费消息。扩容broker集群提前将plain_acl.yml、topics.json 以及subscriptionGroup.json文件拷贝到新集群的相应目录下能够避免此问题。


-- 
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.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org