(rocketmq) branch develop updated: Add some log for gRPC route (#9896)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new cbfd37b251 Add some log for gRPC route (#9896)
cbfd37b251 is described below

commit cbfd37b2513a2610421194fc02ba5918d58c8416
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Fri Dec 5 10:19:27 2025 +0800

    Add some log for gRPC route (#9896)
---
 .../org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
index 20ae3aa6c8..a4e79a856f 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
@@ -63,7 +63,7 @@ public class RouteActivity extends AbstractMessingActivity {
         CompletableFuture<QueryRouteResponse> future = new 
CompletableFuture<>();
         try {
             validateTopic(request.getTopic());
-            List<org.apache.rocketmq.proxy.common.Address> addressList = 
this.convertToAddressList(request.getEndpoints());
+            List<org.apache.rocketmq.proxy.common.Address> addressList = 
this.convertToAddressList(ctx, request.getEndpoints());
 
             String topicName = request.getTopic().getName();
             ProxyTopicRouteData proxyTopicRouteData = 
this.messagingProcessor.getTopicRouteDataForProxy(
@@ -101,7 +101,7 @@ public class RouteActivity extends AbstractMessingActivity {
 
         try {
             validateTopicAndConsumerGroup(request.getTopic(), 
request.getGroup());
-            List<org.apache.rocketmq.proxy.common.Address> addressList = 
this.convertToAddressList(request.getEndpoints());
+            List<org.apache.rocketmq.proxy.common.Address> addressList = 
this.convertToAddressList(ctx, request.getEndpoints());
 
             ProxyTopicRouteData proxyTopicRouteData = 
this.messagingProcessor.getTopicRouteDataForProxy(
                 ctx,
@@ -184,8 +184,7 @@ public class RouteActivity extends AbstractMessingActivity {
         return Permission.NONE;
     }
 
-    protected List<org.apache.rocketmq.proxy.common.Address> 
convertToAddressList(Endpoints endpoints) {
-
+    protected List<org.apache.rocketmq.proxy.common.Address> 
convertToAddressList(ProxyContext ctx, Endpoints endpoints) {
         boolean useEndpointPort = 
ConfigurationManager.getProxyConfig().isUseEndpointPortFromRequest();
 
         List<org.apache.rocketmq.proxy.common.Address> addressList = new 
ArrayList<>();
@@ -198,9 +197,8 @@ public class RouteActivity extends AbstractMessingActivity {
                 
org.apache.rocketmq.proxy.common.Address.AddressScheme.valueOf(endpoints.getScheme().name()),
                 HostAndPort.fromParts(address.getHost(), port)));
         }
-
+        log.debug("gRPC build address. clientId={}, addressList={}", 
ctx.getClientID(), addressList);
         return addressList;
-
     }
 
     protected Map<String /*brokerName*/, Map<Long /*brokerID*/, Broker>> 
buildBrokerMap(