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-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
