test

TaiJuWu · Dec 25, 2024 · 1234fcc · 1234fcc
1 parent 015e80e
commit 1234fcc
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Loggers.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Loggers.java
@@ -212,8 +212,14 @@ private LoggerLevel loggerLevel(org.apache.logging.log4j.Logger logger) {
     }
 
     private boolean isValidRootLoggerName(String namespace) {
-        return VALID_ROOT_LOGGER_NAMES.stream()
-            .anyMatch(rootLoggerNames -> rootLoggerNames.equalsIgnoreCase(namespace));
+        boolean result = false;
+        for (String rootLoggerName : VALID_ROOT_LOGGER_NAMES) {
+            if (rootLoggerName.equalsIgnoreCase(namespace)) {
+                result = true;
+                break;
+            }
+        }
+        return result;
     }
 
     /**
@@ -225,6 +231,6 @@ private boolean isValidRootLoggerName(String namespace) {
      * @return The logger name - returns "root" for empty string, otherwise returns the original logger name
      */
     private String getLoggerName(org.apache.logging.log4j.Logger logger) {
-        return logger.getName().equals(LogManager.ROOT_LOGGER_NAME) ? ROOT_LOGGER_NAME : logger.getName();
+        return logger.getName().equalsIgnoreCase(LogManager.ROOT_LOGGER_NAME) ? ROOT_LOGGER_NAME : logger.getName();
     }
 }