[pulsar] branch master updated: fix debug log authenticate role error (#14784)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 97b7e77a907 fix debug log authenticate role error (#14784)
97b7e77a907 is described below

commit 97b7e77a9075159dd58a279d64f834e85472f437
Author: Dezhi LIiu <33149602+liudezhi2...@users.noreply.github.com>
AuthorDate: Wed Apr 13 08:58:14 2022 +0800

    fix debug log authenticate role error (#14784)
---
 .../main/java/org/apache/pulsar/broker/service/ServerCnx.java    | 9 +++++++--
 1 file changed, 7 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 0102b8d01ad..09dbaa9e8d2 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
@@ -832,8 +832,13 @@ public class ServerCnx extends PulsarHandler implements 
TransportCnx {
             authState = authenticationProvider.newAuthState(clientData, 
remoteAddress, sslSession);
 
             if (log.isDebugEnabled()) {
-                log.debug("[{}] Authenticate role : {}", remoteAddress,
-                    authState != null ? authState.getAuthRole() : null);
+                String role = "";
+                if (authState != null && authState.isComplete()) {
+                    role = authState.getAuthRole();
+                } else {
+                    role = "authentication incomplete or null";
+                }
+                log.debug("[{}] Authenticate role : {}", remoteAddress, role);
             }
 
             state = doAuthentication(clientData, clientProtocolVersion, 
clientVersion);