apache
[Bug] rocketmq5.x版本cpp grpc客户端，producer发送消息，配置rocketmq集群中的所有proxy地址，发送消息始终都只发到一台broker
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.
Programming Language of the Client
C++
Runtime Platform Environment
Red Hat Enterprise Linux Server release 7.9 (Maipo)
RocketMQ Version of the Client/Server
5.0版本cpp客户端
Run or Compiler Version
Red Hat Enterprise Linux Server release 7.9 (Maipo)
Describe the Bug
rocketmq5.x版本cpp grpc客户端，producer发送消息，配置rocketmq集群中的所有proxy地址，发送消息始终都只发到一台broker，不知道啥问题 rocketmq集群部署方式： 3 master + 3 salve，6台机器都开启proxy方式，producer客户端EndPoint配置6个broker的 ip+ grpc port
Steps to Reproduce
cpp grpc客户端，producer发送消息，配置rocketmq集群中的所有proxy地址，持续发送消息
What Did You Expect to See?
无
What Did You See Instead?
无
Additional Context
No response
@41405465 Could you please set the log level to debug and paste what the server reponds when querying topic routes?
是这段不 TopicRouteData for topic=topic_v5_1 has changed. NONE --> topic { name: "topic_v5_1" } permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 1 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 2 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 3 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 4 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 5 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 6 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 7 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 8 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 9 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 10 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 11 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 12 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 13 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 14 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 15 permission: READ_WRITE broker { name: "broker-a" endpoints { scheme: IPv4 addresses { host: "172.26.137.143" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 1 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 2 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 3 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 4 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 5 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 6 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 7 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 8 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 9 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 10 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 11 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 12 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 13 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 14 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 15 permission: READ_WRITE broker { name: "broker-a" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.144" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 1 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 1 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 1 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 1 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 2 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 2 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 2 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 2 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 3 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 3 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 3 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 3 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 4 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 4 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 4 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 4 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 5 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 5 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 5 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 5 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 6 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 6 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 6 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 6 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 7 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 7 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 7 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 7 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 8 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 8 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 8 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 8 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 9 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 9 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 9 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 9 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 10 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 10 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 10 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 10 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 11 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 11 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 11 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 11 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 12 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 12 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 12 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 12 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 13 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 14 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 15 permission: READ_WRITE broker { name: "broker-b" endpoints { scheme: IPv4 addresses { host: "172.26.137.145" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 13 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 14 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 15 permission: READ_WRITE broker { name: "broker-c" endpoints { scheme: IPv4 addresses { host: "172.26.137.156" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 13 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 13 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 14 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 14 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 15 permission: READ_WRITE broker { name: "broker-b" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.155" port: 18081 } } } accept_message_types: NORMAL ,topic { name: "topic_v5_1" } id: 15 permission: READ_WRITE broker { name: "broker-c" id: 1 endpoints { scheme: IPv4 addresses { host: "172.26.137.159" port: 18081 } } } accept_message_types: NORMAL
send消息始终只往broker-b: 172.26.137.145上面发，并且同时在多台机器上跑，也一样
Thanks for your feedback. I would look into this issue soon.
如上截图，发送普通消息，也走到了FIFO获取队列逻辑 message_group参数为absl::make_optionalstd::string()，message_group.has_value()也是true
Thanks for your feedback. I would look into this issue soon.
现在是啥情况，什么时候能有一个真正可用的版本？
This issue is stale because it has been open for 30 days with no activity. It will be closed in 3 days if no further activity occurs.
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "Published by a pub.dev verified publisher"){kind=small}
This issue was closed because it has been inactive for 3 days since being marked as stale.