You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "41405465 (via GitHub)" <gi...@apache.org> on 2023/09/20 09:30:51 UTC
[GitHub] [rocketmq-clients] 41405465 opened a new issue, #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
41405465 opened a new issue, #606:
URL: https://github.com/apache/rocketmq-clients/issues/606
### Before Creating the Bug Report
- [X] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions).
- [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub Discussions](https://github.com/apache/rocketmq-clients/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.6 (Maipo)
### RocketMQ Version of the Client/Server
RocketMQ Broker：5.1.3
c++ client: RocketMQ gRPC Client Cpp SDK 5.0.0
### Run or Compiler Version
_No response_
### Describe the Bug
grpc代理模式下，客户端endpoint填入两个IP：ip1:port1;ip2:port2,broker上proxy.log会报错，如下：
c++客户端报错如下：
初步分析如下：
1、StaticNameServerResolver函数：
将分号隔开的两个IP和端口解析到了vector列表
2、amingScheme::buildAddress函数：
将vector列表里的两个IP拼成了逗号","分割的包含两个IP的string
3、rmq::Endpoints ClientImpl::accessPoint()函数：
根据分号";"来拆分上面第2步的string，但因为找不到分号，将整体作为一个IP，经过absl::StrSplit + absl::MaxSplits(':', 1)
"ip1:port1,ip2:port2"被处理成了IP:"ip1:port1,ip2",PORT:port2
4、将IP:"ip1:port1,ip2",PORT:port2 作为endpoint填入grpc数据协议：
auto addr = new rmq::Address();
addr->set_host(segments[1]);
addr->set_port(port);
access_point.mutable_addresses()->AddAllocated(addr);
### Steps to Reproduce
c++客户端endpoint填入两个IP+端口
### What Did You Expect to See?
c++客户端endpoint填入多个IP+端口能够正常处理
### What Did You See Instead?
客户端报错，Broker端也报错
### Additional Context
_No response_
--
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: commits-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-clients] 41405465 commented on issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
Posted by "41405465 (via GitHub)" <gi...@apache.org>.
41405465 commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1728048778
这样配ok了，谢谢！
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-clients] lizhanhui commented on issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
Posted by "lizhanhui (via GitHub)" <gi...@apache.org>.
lizhanhui commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1727413670
@41405465 If I remember correctly, the scheme we use for endpoint follows this protocol: https://github.com/grpc/grpc/blob/master/doc/naming.md
That said, you should follow this format `ipv4:address[:port][,address[:port],...]` when specify multiple IPv4 addresses
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-clients] 41405465 commented on issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
Posted by "41405465 (via GitHub)" <gi...@apache.org>.
41405465 commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1729693181
两个master,两个slave，都开启proxy，地址配这个：**ipv4:172.26.240.17:18081;172.26.240.18:18081;172.26.240.19:18081;172.26.240.19:28081**
日志如下，明显还是被拆了：
20230921 22:19:20.734482 77 DEBUG GetValueString [RocketMQ] addr: ipv4:172.26.240.17:18081;172.26.240.18:18081;172.26.240.19:18081;172.26.240.19:28081 - IniFile.cpp:78
20230921 22:19:20.734518 77 DEBUG GetValueString [RocketMQ] topic: send_msg_topic - IniFile.cpp:78
20230921 22:19:20.734530 77 DEBUG GetValueString [RocketMQ] group: group1 - IniFile.cpp:78
20230921 22:19:20.734542 77 DEBUG GetValueString [RocketMQ] tag: * - IniFile.cpp:78
20230921 22:19:20.734555 77 DEBUG GetValueInt [RocketMQ] read_write: 1 - IniFile.h:99
[2023/09/21-14:19:20.749 +00:00] [rocketmq_logger] [---I---] [thread 77] ClientManager[ResourceNamespace=] created /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:86
[2023/09/21-14:19:20.751 +00:00] [rocketmq_logger] [---D---] [thread 77] Heartbeat task-id=1 /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:115
[2023/09/21-14:19:20.751 +00:00] [rocketmq_logger] [---I---] [thread 77] Create a RPC client to ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:483
[2023/09/21-14:19:20.761 +00:00] [rocketmq_logger] [---D---] [thread 77] Create a new session for ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:512
[2023/09/21-14:19:20.764 +00:00] [rocketmq_logger] [---D---] [thread 77] [Outbound]Headers of /apache.rocketmq.v2.MessagingService/Telemetry:
x-mq-client-id --> aad2961f757f@77#0_1695305960744
x-mq-client-version --> 5.0.0
x-mq-date-time --> 20230921T141920Z
x-mq-language --> CPP
x-mq-protocol-version --> v2 /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:55
[2023/09/21-14:19:20.805 +00:00] [rocketmq_logger] [---I---] [thread 77] Sync client settings to ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/SessionImpl.cpp:35
[2023/09/21-14:19:20.806 +00:00] [rocketmq_logger] [---D---] [thread 77] ipv4:172.26.240.18:18081,172.26.240.19:28081#fireWrite /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:275
[2023/09/21-14:19:20.808 +00:00] [rocketmq_logger] [---D---] [thread 77] Writing telemetry command to ipv4:172.26.240.18:18081,172.26.240.19:28081: settings {
client_type: PUSH_CONSUMER
access_point {
scheme: IPv4
addresses {
**host: "172.26.240.18:18081,172.26.240.19"
port: 28081**
}
}
request_timeout {
seconds: 3
}
subscription {
group {
name: "group1"
}
subscriptions {
topic {
name: "send_msg_topic"
}
expression {
type: TAG
expression: "*"
}
}
receive_batch_size: 32
long_polling_timeout {
seconds: 30
}
}
user_agent {
language: CPP
version: "5.0.0"
platform: "Linux 64-bit"
hostname: "aad2961f757f"
}
}
/workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:292
[2023/09/21-14:19:20.808 +00:00] [rocketmq_logger] [---D---] [thread 77] [Outbound] /apache.rocketmq.v2.MessagingService/Telemetry: Buffer: 138bytes /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:63
[2023/09/21-14:19:20.825 +00:00] [rocketmq_logger] [---D---] [thread 94] OnWriteDone: true /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:67
[2023/09/21-14:19:20.825 +00:00] [rocketmq_logger] [---D---] [thread 94] ipv4:172.26.240.18:18081,172.26.240.19:28081#fireRead /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:262
[2023/09/21-14:19:20.826 +00:00] [rocketmq_logger] [---D---] [thread 94] ipv4:172.26.240.18:18081,172.26.240.19:28081#fireWrite /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:275
[2023/09/21-14:19:20.826 +00:00] [rocketmq_logger] [---D---] [thread 94] No TelemtryCommand to write. Peer=ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:279
[2023/09/21-14:19:20.830 +00:00] [rocketmq_logger] [---D---] [thread 94] [Inbound]Response metadata of /apache.rocketmq.v2.MessagingService/Telemetry is empty /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:79
[2023/09/21-14:19:20.831 +00:00] [rocketmq_logger] [---D---] [thread 93] [Inbound] /apache.rocketmq.v2.MessagingService/Telemetry
status {
code: OK
message: "OK"
}
settings {
client_type: PUSH_CONSUMER
access_point {
scheme: IPv4
addresses {
**host: "172.26.240.18:18081,172.26.240.19"
port: 28081**
}
}
backoff_policy {
max_attempts: 17
customized_backoff {
next {
seconds: 1
}
next {
seconds: 5
}
next {
seconds: 10
}
next {
seconds: 30
}
next {
seconds: 60
}
next {
seconds: 120
}
next {
seconds: 180
}
next {
seconds: 240
}
next {
seconds: 300
}
next {
seconds: 360
}
next {
seconds: 420
}
next {
seconds: 480
}
next {
seconds: 540
}
next {
seconds: 600
}
next {
seconds: 1200
}
next {
seconds: 1800
}
next {
seconds: 3600
}
next {
seconds: 7200
}
... /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:93
[2023/09/21-14:19:20.831 +00:00] [rocketmq_logger] [---D---] [thread 93] OnReadDone: ok=true /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:99
[2023/09/21-14:19:20.831 +00:00] [rocketmq_logger] [---D---] [thread 93] Read a telemetry command from ipv4:172.26.240.18:18081,172.26.240.19:28081: status {
code: OK
message: "OK"
}
settings {
client_type: PUSH_CONSUMER
access_point {
scheme: IPv4
addresses {
host: "172.26.240.18:18081,172.26.240.19"
port: 28081
}
}
backoff_policy {
max_attempts: 17
customized_backoff {
next {
seconds: 1
}
next {
seconds: 5
}
next {
seconds: 10
}
next {
seconds: 30
}
next {
seconds: 60
}
next {
seconds: 120
}
next {
seconds: 180
}
next {
seconds: 240
}
next {
seconds: 300
}
next {
seconds: 360
}
next {
seconds: 420
}
next {
seconds: 480
}
next {
seconds: 540
}
next {
seconds: 600
}
next {
seconds: 1200
}
next {
seconds: 1800
}
next {
seconds: 3600
}
next {
seconds: 7200
}
}
}
request_timeout {
seconds: 3
}
subscription {
group {
name: "group1"
}
subscriptions {
topic {
name: "send_msg_topic"
}
expression {
type: TAG
expression: "*"
}
}
fifo: false
receive_batch_size: 32
long_polling_timeout {
seconds: 20
}
}
user_agent {
language: CPP
version: "5.0.0"
platform: "Linux 64-bit"
hostname: "aad2961f757f"
}
metric {
}
}
/workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:113
[2023/09/21-14:19:20.831 +00:00] [rocketmq_logger] [---I---] [thread 93] Received settings from ipv4:172.26.240.18:18081,172.26.240.19:28081: client_type: PUSH_CONSUMER
access_point {
scheme: IPv4
addresses {
host: "172.26.240.18:18081,172.26.240.19"
port: 28081
}
}
backoff_policy {
max_attempts: 17
customized_backoff {
next {
seconds: 1
}
next {
seconds: 5
}
next {
seconds: 10
}
next {
seconds: 30
}
next {
seconds: 60
}
next {
seconds: 120
}
next {
seconds: 180
}
next {
seconds: 240
}
next {
seconds: 300
}
next {
seconds: 360
}
next {
seconds: 420
}
next {
seconds: 480
}
next {
seconds: 540
}
next {
seconds: 600
}
next {
seconds: 1200
}
next {
seconds: 1800
}
next {
seconds: 3600
}
next {
seconds: 7200
}
}
}
request_timeout {
seconds: 3
}
subscription {
group {
name: "group1"
}
subscriptions {
topic {
name: "send_msg_topic"
}
expression {
type: TAG
expression: "*"
}
}
fifo: false
receive_batch_size: 32
long_polling_timeout {
seconds: 20
}
}
user_agent {
language: CPP
version: "5.0.0"
platform: "Linux 64-bit"
hostname: "aad2961f757f"
}
metric {
}
/workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:123
[2023/09/21-14:19:20.832 +00:00] [rocketmq_logger] [---D---] [thread 93] ipv4:172.26.240.18:18081,172.26.240.19:28081#fireRead /workspaces/l2test/l2test/libs/cpp/source/client/TelemetryBidiReactor.cpp:262
[2023/09/21-14:19:20.833 +00:00] [rocketmq_logger] [---E---] [thread 77] Unknown metric address scheme /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:217
[2023/09/21-14:19:20.834 +00:00] [rocketmq_logger] [---I---] [thread 77] Create inflight route query cache for topic=send_msg_topic /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:304
[2023/09/21-14:19:20.834 +00:00] [rocketmq_logger] [---D---] [thread 77] Name server connection URL: ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:546
[2023/09/21-14:19:20.834 +00:00] [rocketmq_logger] [---D---] [thread 77] Query route request: topic {
name: "send_msg_topic"
}
endpoints {
scheme: IPv4
addresses {
host: "172.26.240.18:18081,172.26.240.19"
port: 28081
}
}
/workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:547
[2023/09/21-14:19:20.835 +00:00] [rocketmq_logger] [---T---] [thread 77] Skip MAC address of network interface lo /workspaces/l2test/l2test/libs/cpp/source/base/UtilAll.cpp:84
[2023/09/21-14:19:20.835 +00:00] [rocketmq_logger] [---D---] [thread 77] Use MAC address of network interface eth0 /workspaces/l2test/l2test/libs/cpp/source/base/UtilAll.cpp:87
[2023/09/21-14:19:20.836 +00:00] [rocketmq_logger] [---D---] [thread 77] [Outbound]Headers of /apache.rocketmq.v2.MessagingService/QueryRoute:
x-mq-client-id --> aad2961f757f@77#0_1695305960744
x-mq-client-version --> 5.0.0
x-mq-date-time --> 20230921T141920Z
x-mq-language --> CPP
x-mq-protocol-version --> v2
x-mq-request-id --> 010242AC110005004DE8EA1D0501000000 /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:55
[2023/09/21-14:19:20.836 +00:00] [rocketmq_logger] [---D---] [thread 77] [Outbound] /apache.rocketmq.v2.MessagingService/QueryRoute: Buffer: 63bytes /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:63
[2023/09/21-14:19:20.841 +00:00] [rocketmq_logger] [---D---] [thread 93] [Inbound]Response metadata of /apache.rocketmq.v2.MessagingService/QueryRoute is empty /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:79
[2023/09/21-14:19:20.841 +00:00] [rocketmq_logger] [---D---] [thread 93] [Inbound] /apache.rocketmq.v2.MessagingService/QueryRoute
status {
code: INTERNAL_SERVER_ERROR
message: "**Unparseable port number: 172.26.240.18:18081,172.26.240.19. IllegalArgumentException.** com.google.common.net.HostAndPort.fromString(HostAndPort.java:201)"
}
/workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:91
[2023/09/21-14:19:20.841 +00:00] [rocketmq_logger] [---D---] [thread 86] RPC[Query route of topic=send_msg_topic from ipv4:172.26.240.18:18081,172.26.240.19:28081] costs 6ms /workspaces/l2test/l2test/libs/cpp/source/base/include/InvocationContext.h:64
[2023/09/21-14:19:20.841 +00:00] [rocketmq_logger] [---W---] [thread 86] InternalServerError: Unparseable port number: 172.26.240.18:18081,172.26.240.19. IllegalArgumentException. com.google.common.net.HostAndPort.fromString(HostAndPort.java:201). Host=ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:622
[2023/09/21-14:19:20.841 +00:00] [rocketmq_logger] [---W---] [thread 86] Failed to resolve route for topic=send_msg_topic from ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:328
[2023/09/21-14:19:20.842 +00:00] [rocketmq_logger] [---I---] [thread 86] Change current name server from ipv4:172.26.240.18:18081,172.26.240.19:28081 to ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:331
[2023/09/21-14:19:20.842 +00:00] [rocketmq_logger] [---W---] [thread 86] Yuck! route for send_msg_topic is invalid. Cause: Server side interval error /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:438
[2023/09/21-14:19:20.842 +00:00] [rocketmq_logger] [---D---] [thread 86] Apply cached callbacks with acquired route data for topic=send_msg_topic /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:430
[2023/09/21-14:19:20.843 +00:00] [rocketmq_logger] [---I---] [thread 77] Fetched route for 0 out of 1 topics /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:492
[2023/09/21-14:19:20.843 +00:00] [rocketmq_logger] [---I---] [thread 77] start concurrently consume service: group1 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:77
[2023/09/21-14:19:20.844 +00:00] [rocketmq_logger] [---W---] [thread 77] No hosts to send heartbeat to at present /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:389
[2023/09/21-14:19:20.844 +00:00] [rocketmq_logger] [---I---] [thread 77] PushConsumer started, groupName=group1 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:95
[2023/09/21-14:19:20.945 +00:00] [rocketmq_logger] [---I---] [thread 89] Execute task: scan-assignment-task. Use-count: 2 /workspaces/l2test/l2test/libs/cpp/source/scheduler/SchedulerImpl.cpp:165
[2023/09/21-14:19:20.945 +00:00] [rocketmq_logger] [---D---] [thread 89] Start of assignment scanning /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:167
[2023/09/21-14:19:20.945 +00:00] [rocketmq_logger] [---D---] [thread 89] Scan assignments for send_msg_topic /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:178
[2023/09/21-14:19:20.945 +00:00] [rocketmq_logger] [---I---] [thread 89] Create inflight route query cache for topic=send_msg_topic /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:304
[2023/09/21-14:19:20.946 +00:00] [rocketmq_logger] [---D---] [thread 89] Name server connection URL: ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:546
[2023/09/21-14:19:20.946 +00:00] [rocketmq_logger] [---D---] [thread 89] Query route request: topic {
name: "send_msg_topic"
}
endpoints {
scheme: IPv4
addresses {
host: "172.26.240.18:18081,172.26.240.19"
port: 28081
}
}
/workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:547
[2023/09/21-14:19:20.946 +00:00] [rocketmq_logger] [---D---] [thread 89] [Outbound]Headers of /apache.rocketmq.v2.MessagingService/QueryRoute:
x-mq-client-id --> aad2961f757f@77#0_1695305960744
x-mq-client-version --> 5.0.0
x-mq-date-time --> 20230921T141920Z
x-mq-language --> CPP
x-mq-protocol-version --> v2
x-mq-request-id --> 010242AC110005004DE8EA1D0502000000 /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:55
[2023/09/21-14:19:20.947 +00:00] [rocketmq_logger] [---D---] [thread 89] [Outbound] /apache.rocketmq.v2.MessagingService/QueryRoute: Buffer: 63bytes /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:63
[2023/09/21-14:19:20.948 +00:00] [rocketmq_logger] [---D---] [thread 89] End of assignment scanning. /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:190
[2023/09/21-14:19:20.951 +00:00] [rocketmq_logger] [---D---] [thread 94] [Inbound]Response metadata of /apache.rocketmq.v2.MessagingService/QueryRoute is empty /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:79
[2023/09/21-14:19:20.951 +00:00] [rocketmq_logger] [---D---] [thread 94] [Inbound] /apache.rocketmq.v2.MessagingService/QueryRoute
status {
code: INTERNAL_SERVER_ERROR
message: "**Unparseable port number: 172.26.240.18:18081,172.26.240.19. IllegalArgumentException**. com.google.common.net.HostAndPort.fromString(HostAndPort.java:201)"
}
/workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:91
[2023/09/21-14:19:20.951 +00:00] [rocketmq_logger] [---D---] [thread 87] RPC[Query route of topic=send_msg_topic from ipv4:172.26.240.18:18081,172.26.240.19:28081] costs 5ms /workspaces/l2test/l2test/libs/cpp/source/base/include/InvocationContext.h:64
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---W---] [thread 87] InternalServerError: Unparseable port number: 172.26.240.18:18081,172.26.240.19. IllegalArgumentException. com.google.common.net.HostAndPort.fromString(HostAndPort.java:201). Host=ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:622
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---W---] [thread 87] Failed to resolve route for topic=send_msg_topic from ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:328
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---I---] [thread 87] Change current name server from ipv4:172.26.240.18:18081,172.26.240.19:28081 to ipv4:172.26.240.18:18081,172.26.240.19:28081 /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:331
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---W---] [thread 87] Yuck! route for send_msg_topic is invalid. Cause: Server side interval error /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:438
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---D---] [thread 87] Apply cached callbacks with acquired route data for topic=send_msg_topic /workspaces/l2test/l2test/libs/cpp/source/rocketmq/ClientImpl.cpp:430
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---W---] [thread 87] Failed to select a broker to query assignment for group=group1, topic=send_msg_topic /workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:225
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---D---] [thread 87] QueryAssignmentRequest: topic {
name: "send_msg_topic"
}
group {
name: "group1"
}
endpoints {
scheme: IPv4
addresses {
host: "172.26.240.18:18081,172.26.240.19"
port: 28081
}
}
/workspaces/l2test/l2test/libs/cpp/source/rocketmq/PushConsumerImpl.cpp:231
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---D---] [thread 87] Prepare to send query assignment request to broker[address=] /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:651
[2023/09/21-14:19:20.952 +00:00] [rocketmq_logger] [---I---] [thread 87] Create a RPC client to /workspaces/l2test/l2test/libs/cpp/source/client/ClientManagerImpl.cpp:483
E0921 14:19:20.954526681 87 dns_resolver_ares.cc:459] no server name supplied in dns URI
E0921 14:19:20.955121903 87 channel.cc:119] channel stack builder failed: UNKNOWN: the target uri is not valid: dns:///
[2023/09/21-14:19:20.956 +00:00] [rocketmq_logger] [---D---] [thread 87] [Outbound]Headers of /apache.rocketmq.v2.MessagingService/QueryAssignment:
x-mq-client-id --> aad2961f757f@77#0_1695305960744
x-mq-client-version --> 5.0.0
x-mq-date-time --> 20230921T141920Z
x-mq-language --> CPP
x-mq-protocol-version --> v2
x-mq-request-id --> 010242AC110005004DE8EA1D0503000000 /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:55
[2023/09/21-14:19:20.956 +00:00] [rocketmq_logger] [---D---] [thread 87] [Outbound] /apache.rocketmq.v2.MessagingService/QueryAssignment: Buffer: 73bytes /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:63
[2023/09/21-14:19:20.959 +00:00] [rocketmq_logger] [---D---] [thread 94] [Inbound]Response metadata of /apache.rocketmq.v2.MessagingService/QueryAssignment is empty /workspaces/l2test/l2test/libs/cpp/source/client/LogInterceptor.cpp:79
[2023/09/21-14:19:20.959 +00:0
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-clients] 41405465 closed issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
Posted by "41405465 (via GitHub)" <gi...@apache.org>.
41405465 closed issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
URL: https://github.com/apache/rocketmq-clients/issues/606
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "0902horn (via GitHub)" <gi...@apache.org>.
0902horn commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1751928921
> try "127.0.0.1:8080;127.0.2:8081"
That's right.
See https://github.com/apache/rocketmq-clients/blob/16bc4a8c61717b038cfb4b17de00bd3969e91290/cpp/source/rocketmq/ClientImpl.cpp#L73
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "0902horn (via GitHub)" <gi...@apache.org>.
0902horn commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1751935951
> https://github.com/apache/rocketmq-clients/blob/16bc4a8c61717b038cfb4b17de00bd3969e91290/cpp/source/rocketmq/ClientImpl.cpp#L73
And I think we could fix this issue by changing ';' in this line to ','. @lizhanhui
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "lizhanhui (via GitHub)" <gi...@apache.org>.
lizhanhui commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1751944437
@0902horn It's would be nice to file a pull request, making it compliant to gRPC naming scheme. To make the change non-breaking, we'd better make it backward compatible, aka, accepting both ',' and ';' a the same time.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "0902horn (via GitHub)" <gi...@apache.org>.
0902horn commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1752249774
> @0902horn It's would be nice to file a pull request, making it compliant to gRPC naming scheme. To make the change non-breaking, we'd better make it backward compatible, aka, accepting both ',' and ';' a the same time.
Cool! Shall we support this feature for clients of other languages as well?
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-clients] 41405465 commented on issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
Posted by "41405465 (via GitHub)" <gi...@apache.org>.
41405465 commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1729623739
> @41405465 If I remember correctly, the scheme we use for endpoint follows this protocol: https://github.com/grpc/grpc/blob/master/doc/naming.md
>
> That said, you should follow this format `ipv4:address[:port][,address[:port],...]` when specify multiple IPv4 addresses
**ipv4:172.26.240.17:18081,172.26.240.18:18081**，这样配置地址，还是不对，请你们验证下多个地址要怎么配
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "lizhanhui (via GitHub)" <gi...@apache.org>.
lizhanhui commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1752255959
> > @0902horn It's would be nice to file a pull request, making it compliant to gRPC naming scheme. To make the change non-breaking, we'd better make it backward compatible, aka, accepting both ',' and ';' a the same time.
>
> Cool! Shall we support this feature for clients of other languages as well?
Definitely yes. Keeping features and usage consistent among language bindings is of consensus and treated as top priority.
You are welcome to contribute on this issue.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.
francisoliverlee commented on issue #606:
URL: https://github.com/apache/rocketmq-clients/issues/606#issuecomment-1751913907
try "127.0.0.1:8080;127.0.2:8081"
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题 [rocketmq-clients]
Posted by "lizhanhui (via GitHub)" <gi...@apache.org>.
lizhanhui closed issue #606: [Bug] RocketMQ5.0代理grpc模式下 c++客户端填入多个endpoint问题
URL: https://github.com/apache/rocketmq-clients/issues/606
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org