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

…IP address (apache#19028) (cherry picked from commit d8569cd)
datastax · Jan 31, 2023 · 5385f3b · 5385f3b
1 parent 0dfbc61
commit 5385f3b
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
@@ -206,7 +206,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
@@ -217,7 +217,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
@@ -61,7 +61,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);
     }