ijuma commented on code in PR #12587:
URL: https://github.com/apache/kafka/pull/12587#discussion_r962039832


##########
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/expiring/ExpiringCredentialRefreshingLogin.java:
##########
@@ -421,17 +419,17 @@ private void reLogin() throws LoginException, 
ExitRefresherThreadDueToIllegalSta
                     throw new 
ExitRefresherThreadDueToIllegalStateException(String.format(
                             "Subject's private credentials still contains the 
previous, soon-to-expire instance of %s even though login() followed by 
logout() was invoked; exiting refresh thread",
                             expiringCredential.getClass().getName()));
-                principalName = expiringCredential.principalName();
                 if (log.isDebugEnabled())
                     log.debug("[Principal={}]: It is an expiring credential 
after re-login as expected",
                             principalLogText());
             }
         }
     }
 
-    private String principalLogText() {
-        return expiringCredential == null ? principalName

Review Comment:
   @rondagostino Do you recall why we had this code? I don't understand how 
we'd have no expiring credential and a non-null principal name. It seems like 
the latter would always be set from the expiring credential? Or am I missing 
something?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to