[fix][client] Prevent DNS reverse lookup when physical address is an …

…IP address (#19028) (cherry picked from commit d8569cd)
apache · Jan 31, 2023 · 80bb1b7 · 80bb1b7
1 parent 4ac2419
commit 80bb1b7
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java b/...-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
@@ -205,7 +205,7 @@ public void failure(Throwable failure) {
     private URI replaceWithNew(InetSocketAddress address, URI uri) {
         String originalUri = uri.toString();
         String newUri = (originalUri.split(":")[0] + "://")
-                + address.getHostName() + ":"
+                + address.getHostString() + ":"
                 + address.getPort()
                 + uri.getRawPath();
         if (uri.getRawQuery() != null) {

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java
@@ -209,7 +209,7 @@ private CompletableFuture<ClientCnx> createConnection(InetSocketAddress logicalA
                 cnx.setTargetBroker(logicalAddress);
             }
 
-            cnx.setRemoteHostName(physicalAddress.getHostName());
+            cnx.setRemoteHostName(physicalAddress.getHostString());
 
             cnx.connectionFuture().thenRun(() -> {
                 if (log.isDebugEnabled()) {

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarServiceNameResolver.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarServiceNameResolver.java
@@ -63,7 +63,7 @@ public InetSocketAddress resolveHost() {
     @Override
     public URI resolveHostUri() {
         InetSocketAddress host = resolveHost();
-        String hostUrl = serviceUri.getServiceScheme() + "://" + host.getHostName() + ":" + host.getPort();
+        String hostUrl = serviceUri.getServiceScheme() + "://" + host.getHostString() + ":" + host.getPort();
         return URI.create(hostUrl);
     }