diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java index f150a084237f5..f51e96ca9a779 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java @@ -156,7 +156,7 @@ default CompletableFuture authenticateHttpRequestAsync(HttpServletReque @Deprecated default boolean authenticateHttpRequest(HttpServletRequest request, HttpServletResponse response) throws Exception { AuthenticationState authenticationState = newHttpAuthState(request); - String role = authenticate(authenticationState.getAuthDataSource()); + String role = authenticateAsync(authenticationState.getAuthDataSource()).get(); request.setAttribute(AuthenticatedRoleAttributeName, role); request.setAttribute(AuthenticatedDataAttributeName, authenticationState.getAuthDataSource()); return true;