Skip to content

Commit cbfd37b

Browse files
authored
Add some log for gRPC route (#9896)
1 parent d7e27d6 commit cbfd37b

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ public CompletableFuture<QueryRouteResponse> queryRoute(ProxyContext ctx, QueryR
6363
CompletableFuture<QueryRouteResponse> future = new CompletableFuture<>();
6464
try {
6565
validateTopic(request.getTopic());
66-
List<org.apache.rocketmq.proxy.common.Address> addressList = this.convertToAddressList(request.getEndpoints());
66+
List<org.apache.rocketmq.proxy.common.Address> addressList = this.convertToAddressList(ctx, request.getEndpoints());
6767

6868
String topicName = request.getTopic().getName();
6969
ProxyTopicRouteData proxyTopicRouteData = this.messagingProcessor.getTopicRouteDataForProxy(
@@ -101,7 +101,7 @@ public CompletableFuture<QueryAssignmentResponse> queryAssignment(ProxyContext c
101101

102102
try {
103103
validateTopicAndConsumerGroup(request.getTopic(), request.getGroup());
104-
List<org.apache.rocketmq.proxy.common.Address> addressList = this.convertToAddressList(request.getEndpoints());
104+
List<org.apache.rocketmq.proxy.common.Address> addressList = this.convertToAddressList(ctx, request.getEndpoints());
105105

106106
ProxyTopicRouteData proxyTopicRouteData = this.messagingProcessor.getTopicRouteDataForProxy(
107107
ctx,
@@ -184,8 +184,7 @@ protected Permission convertToPermission(int perm) {
184184
return Permission.NONE;
185185
}
186186

187-
protected List<org.apache.rocketmq.proxy.common.Address> convertToAddressList(Endpoints endpoints) {
188-
187+
protected List<org.apache.rocketmq.proxy.common.Address> convertToAddressList(ProxyContext ctx, Endpoints endpoints) {
189188
boolean useEndpointPort = ConfigurationManager.getProxyConfig().isUseEndpointPortFromRequest();
190189

191190
List<org.apache.rocketmq.proxy.common.Address> addressList = new ArrayList<>();
@@ -198,9 +197,8 @@ protected List<org.apache.rocketmq.proxy.common.Address> convertToAddressList(En
198197
org.apache.rocketmq.proxy.common.Address.AddressScheme.valueOf(endpoints.getScheme().name()),
199198
HostAndPort.fromParts(address.getHost(), port)));
200199
}
201-
200+
log.debug("gRPC build address. clientId={}, addressList={}", ctx.getClientID(), addressList);
202201
return addressList;
203-
204202
}
205203

206204
protected Map<String /*brokerName*/, Map<Long /*brokerID*/, Broker>> buildBrokerMap(

0 commit comments

Comments
 (0)