From f24b41c891f1bc09fcbc437994a9ffaf93ce90ad Mon Sep 17 00:00:00 2001 From: Sanjeev Kulkarni Date: Wed, 18 Mar 2020 12:14:35 -0700 Subject: [PATCH] Add more logging during refresh credentials path (#6551) Co-authored-by: Sanjeev Kulkarni --- .../main/java/org/apache/pulsar/broker/service/ServerCnx.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);