[Bug] rocketmq 2m2s集群环境下，客户端使用golang/v5.1.0-rc.1，只能及时消费其中一个broker的消息，另一个broker上的消息不能及时消费 ，有很大的延时

[heshiyingx]

trafficstars

Before Creating the Bug Report

• [X] I found a bug, not just asking a question, which should be created in GitHub Discussions.

• [X] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.

• [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Runtime platform environment

运行环境：macOS14.7(intel)，docker 使用镜像：apache/rocketmq:5.3.0 docker_compose整体文件包括配置如下： docker-compose.zip

RocketMQ version

使用的是官方镜像，apache/rocketmq:5.3.0

JDK Version

openjdk version "1.8.0_422" OpenJDK Runtime Environment (Temurin)(build 1.8.0_422-b05) OpenJDK 64-Bit Server VM (Temurin)(build 25.422-b05, mixed mode)

Describe the Bug

在双主双从的集群环境下，创建一个topic，持续的生产消息，多个消费者只能及时消费其中一个broker的消息。另一个broker中的消息不能被及时消费。有很大的延时。(消费者空闲)

Steps to Reproduce

• 下载docker_compose文件docker-compose.zip
• 修改所有broker配置文件中brokerIP1为本机IP
• 使用docker_compose启动集群
• 进入某个容器，使用sh mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c <cluster_name> -a +message.type=NORMAL命令创建topic。或者使用dashboard创建topic
• 使用https://github.com/apache/rocketmq-clients/archive/refs/tags/golang/v5.1.0-rc.1.zip这个SDK生产消息，然后同样使用这个SDK中的示例代码，修改EndPoint和topic,使用simple_consumer中的消费者启动.
• 然后就能观测到只能及时消费一部分消息(经排查，及时消费到的消息属于一个broker,未及时消费到的消息属于另外一个broker)

What Did You Expect to See?

消费者能够及时消费集群中所有的消息

What Did You See Instead?

现在只能及时消费其中一个broker的消息

Additional Context

No response

[dyrnq]

your docker-compose.yml usedefault bridge network, you should use User-defined bridge networks priority for use container`s name for connect earch other.

[github-actions[bot]]

This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.

[github-actions[bot]]

This issue was closed because it has been inactive for 3 days since being marked as stale.