diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java index d9960c5a1ec31..9b8b7fb0aed14 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java @@ -327,6 +327,7 @@ protected void handleConnect(CommandConnect connect) { } authState = authenticationProvider.newAuthState(clientData, remoteAddress, sslSession); + authenticationData = authState.getAuthDataSource(); doAuthentication(clientData); } catch (Exception e) { LOG.warn("[{}] Unable to authenticate: ", remoteAddress, e);