diff --git a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java index bc8400c19a2..16af92cc54d 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java @@ -85,7 +85,7 @@ public ProducerTableInfo getProducerTable() { if (map.containsKey(group)) { map.get(group).add(new ProducerInfo( clientChannelInfo.getClientId(), - clientChannelInfo.getChannel().remoteAddress().toString(), + RemotingHelper.parseChannelRemoteAddr(clientChannelInfo.getChannel()), clientChannelInfo.getLanguage(), clientChannelInfo.getVersion(), clientChannelInfo.getLastUpdateTimestamp() @@ -93,7 +93,7 @@ public ProducerTableInfo getProducerTable() { } else { map.put(group, new ArrayList<>(Collections.singleton(new ProducerInfo( clientChannelInfo.getClientId(), - clientChannelInfo.getChannel().remoteAddress().toString(), + RemotingHelper.parseChannelRemoteAddr(clientChannelInfo.getChannel()), clientChannelInfo.getLanguage(), clientChannelInfo.getVersion(), clientChannelInfo.getLastUpdateTimestamp()