Add more logging during refresh credentials path
@@ -522,7 +522,7 @@ public class ServerCnx extends PulsarHandler {
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 class ServerCnx extends PulsarHandler {
}
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);
