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);
}