diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataHttp.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataHttp.java index 9ffb29c0376a0..8a8dda2f17715 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataHttp.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataHttp.java @@ -18,7 +18,6 @@ */ package org.apache.pulsar.broker.authentication; -import io.netty.util.NetUtil; import java.net.InetSocketAddress; import java.net.SocketAddress; @@ -36,9 +35,7 @@ public AuthenticationDataHttp(HttpServletRequest request) { throw new IllegalArgumentException(); } this.request = request; - this.remoteAddress = - new InetSocketAddress(NetUtil.createInetAddressFromIpAddressString(request.getRemoteAddr()), - request.getRemotePort()); + this.remoteAddress = InetSocketAddress.createUnresolved(request.getRemoteAddr(), request.getRemotePort()); } /*