wangyanan0629 commented on issue #2653:
URL: https://github.com/apache/rocketmq/issues/2653#issuecomment-781248098
> > > > 只有在广播模式的时候可以连上broker2,集群模式的时候只能消费broker1上的消息
> > >
> > >
> > > 消费者只启动了单台吗？是以容器的方式启动的吗？
> >
> >
> > 用的是docker容器启动的集群
>
>
是同一台机器上有多个docker容器吗？是不是instanceName相同导致的，可以consumer强制setInstanceName，保证每一个consumer的instanceName都独一无二试试
这个是docker-compose的配置
`version: '3.5'
services:
namesrv1:
image: rocketmqinc/rocketmq:4.3.0
container_name: namesrv1
ports:
- 9876:9876
volumes:
- /opt/rocketmq/namesrv1/log:/opt/logs
- /opt/rocketmq/namesrv1/data:/opt/store
command: sh mqnamesrv
networks:
rocketmq:
aliases:
- namesrv1
namesrv2:
image: rocketmqinc/rocketmq:4.3.0
container_name: namesrv2
ports:
- 9877:9876
volumes:
- /opt/rocketmq/namesrv2/log:/opt/logs
- /opt/rocketmq/namesrv2/data:/opt/store
command: sh mqnamesrv
networks:
rocketmq:
aliases:
- namesrv2
broker-m-1:
image: rocketmqinc/rocketmq:4.3.0
container_name: broker-m-1
links:
- namesrv1:namesrv1
- namesrv2:namesrv2
ports:
- 10909:10909
- 10911:10911
- 10912:10912
environment:
TZ: Asia/Shanghai
NAMESRV_ADDR: "namesrv1:9876"
JAVA_OPTS: "-Duser.home=/opt"
JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
volumes:
- /opt/rocketmq/broker-m-1/log:/opt/logs
- /opt/rocketmq/broker-m-1/data:/opt/store
-
/opt/rocketmq/broker-m-1/conf/broker-m-1.conf:/opt/rocketmq-4.3.0/conf/broker-m-1.conf
command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker-m-1.conf
autoCreateTopicEnable=true &
networks:
rocketmq:
aliases:
- broker-m-1
broker-s-1:
image: rocketmqinc/rocketmq:4.3.0
container_name: broker-s-1
links:
- namesrv1:namesrv1
- namesrv2:namesrv2
ports:
- 11909:10909
- 11911:11911
- 11912:10912
environment:
TZ: Asia/Shanghai
NAMESRV_ADDR: "namesrv1:9876"
JAVA_OPTS: "-Duser.home=/opt"
JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
volumes:
- /opt/rocketmq/broker-s-1/log:/opt/logs
- /opt/rocketmq/broker-s-1/data:/opt/store
-
/opt/rocketmq/broker-s-1/conf/broker-s-1.conf:/opt/rocketmq-4.3.0/conf/broker-s-1.conf
command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker-s-1.conf
autoCreateTopicEnable=true &
networks:
rocketmq:
aliases:
- broker-s-1
broker-m-2:
image: rocketmqinc/rocketmq:4.3.0
container_name: broker-m-2
links:
- namesrv1:namesrv1
- namesrv2:namesrv1
ports:
- 12909:10909
- 12911:12911
- 12912:10912
environment:
TZ: Asia/Shanghai
NAMESRV_ADDR: "namesrv1:9876"
JAVA_OPTS: "-Duser.home=/opt"
JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
volumes:
- /opt/rocketmq/broker-m-2/log:/opt/logs
- /opt/rocketmq/broker-m-2/data:/opt/store
-
/opt/rocketmq/broker-m-2/conf/broker-m-2.conf:/opt/rocketmq-4.3.0/conf/broker-m-2.conf
command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker-m-2.conf
autoCreateTopicEnable=true &
networks:
rocketmq:
aliases:
- broker-m-2
broker-s-2:
image: rocketmqinc/rocketmq:4.3.0
container_name: broker-s-2
links:
- namesrv1:namesrv1
- namesrv2:namesrv2
ports:
- 13909:10909
- 13911:13911
- 13912:10912
environment:
TZ: Asia/Shanghai
NAMESRV_ADDR: "namesrv1:9876"
JAVA_OPTS: "-Duser.home=/opt"
JAVA_OPT_EXT: "-server -Xms256m -Xmx256m -Xmn256m"
volumes:
- /opt/rocketmq/broker-s-2/log:/opt/logs
- /opt/rocketmq/broker-s-2/data:/opt/store
-
/opt/rocketmq/broker-s-2/conf/broker-s-2.conf:/opt/rocketmq-4.3.0/conf/broker-s-2.conf
command: sh mqbroker -c /opt/rocketmq-4.3.0/conf/broker-s-2.conf
autoCreateTopicEnable=true &
networks:
rocketmq:
aliases:
- broker-s-2
rocketmq-console:
image: styletang/rocketmq-console-ng
container_name: rocketmq-console
ports:
- 8090:8080
environment:
JAVA_OPTS: -Drocketmq.namesrv.addr=namesrv1:9876;namesrv2:9877
-Dcom.rocketmq.sendMessageWithVIPChannel=false
networks:
rocketmq:
aliases:
- rocketmq-console
networks:
rocketmq:
name: rocketmq
driver: bridge`
----------------------------------------------------------------
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]
