diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java index 038cbab01233e..d92736524067a 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java @@ -522,7 +522,7 @@ private State doAuthentication(AuthData clientData, log.warn("[{}] Principal cannot be changed during an authentication refresh", remoteAddress); ctx.close(); } else { - log.info("[{}] Refreshed authentication credentials", remoteAddress); + log.info("[{}] Refreshed authentication credentials for role {}", remoteAddress, authRole); } } } @@ -559,7 +559,7 @@ public void refreshAuthenticationCredentials() { } ctx.executor().execute(SafeRun.safeRun(() -> { - log.info("[{}] Refreshing authentication credentials", remoteAddress); + log.info("[{}] Refreshing authentication credentials for originalPrincipal {} and authRole {}", remoteAddress, originalPrincipal, this.authRole); if (!supportsAuthenticationRefresh()) { log.warn("[{}] Closing connection because client doesn't support auth credentials refresh", remoteAddress);