commit 36897fc3edd67a44c322ed983f20482d47b7dfce
author Alexander Preuß <11444089+alpreu@users.noreply.github.com> Wed Dec 15 11:13:25 2021 +0100
committer Chesnay Schepler <chesnay@apache.org> Thu Jan 26 16:40:41 2023 +0100
tree 6808cd782a8a7033dced2fc58c80c0901a92fcbd
parent d6b691e06007d0f0cd8f11f8d941bcef96c43fa9

[FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer

flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java

diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
index 2e37d91..a5c6097 100644
--- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
+++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java
@@ -56,16 +56,16 @@
      */
     public static KafkaContainer createKafkaContainer(String dockerImageVersion, Logger logger) {
         String logLevel;
-        if (logger.isErrorEnabled()) {
-            logLevel = "ERROR";
-        } else if (logger.isTraceEnabled()) {
+        if (logger.isTraceEnabled()) {
             logLevel = "TRACE";
         } else if (logger.isDebugEnabled()) {
             logLevel = "DEBUG";
-        } else if (logger.isWarnEnabled()) {
-            logLevel = "WARN";
         } else if (logger.isInfoEnabled()) {
             logLevel = "INFO";
+        } else if (logger.isWarnEnabled()) {
+            logLevel = "WARN";
+        } else if (logger.isErrorEnabled()) {
+            logLevel = "ERROR";
         } else {
             logLevel = "OFF";
         }