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

mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 03259f6f414 KAFKA-15500: Fix condition in SslPrincipalMapper.java 
(#14441)
03259f6f414 is described below

commit 03259f6f414425c1c0b396eb31f0f4b17f93b424
Author: rykovsi <[email protected]>
AuthorDate: Fri Sep 29 15:00:06 2023 +0300

    KAFKA-15500: Fix condition in SslPrincipalMapper.java (#14441)
    
    
    Reviewers: Mickael Maison <[email protected]>, Divij Vaidya 
<[email protected]>
---
 .../java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java
 
b/clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java
index 33da9642d97..0fb83281bf8 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/security/ssl/SslPrincipalMapper.java
@@ -140,7 +140,7 @@ public class SslPrincipalMapper {
 
             if (toLowerCase && result != null) {
                 result = result.toLowerCase(Locale.ENGLISH);
-            } else if (toUpperCase & result != null) {
+            } else if (toUpperCase && result != null) {
                 result = result.toUpperCase(Locale.ENGLISH);
             }
 

Reply via email to