Updated missing version and logging info

thinker0 · Aug 21, 2020 · b369458 · b369458
1 parent 6854494
commit b369458
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 5 deletions.
diff --git a/app/controllers/Logkafka.scala b/app/controllers/Logkafka.scala
@@ -288,8 +288,15 @@ class Logkafka (val cc: ControllerComponents, val kafkaManagerContext: KafkaMana
       case Kafka_2_1_0 => LogkafkaNewConfigs.configNames(Kafka_2_1_0).map(n => (n,LKConfig(n,None))).toMap
       case Kafka_2_1_1 => LogkafkaNewConfigs.configNames(Kafka_2_1_1).map(n => (n,LKConfig(n,None))).toMap
       case Kafka_2_2_0 => LogkafkaNewConfigs.configNames(Kafka_2_2_0).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_2_1 => LogkafkaNewConfigs.configNames(Kafka_2_2_1).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_2_2 => LogkafkaNewConfigs.configNames(Kafka_2_2_2).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_3_0 => LogkafkaNewConfigs.configNames(Kafka_2_2_0).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_3_1 => LogkafkaNewConfigs.configNames(Kafka_2_2_1).map(n => (n,LKConfig(n,None))).toMap
       case Kafka_2_4_0 => LogkafkaNewConfigs.configNames(Kafka_2_4_0).map(n => (n,LKConfig(n,None))).toMap
       case Kafka_2_4_1 => LogkafkaNewConfigs.configNames(Kafka_2_4_1).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_5_0 => LogkafkaNewConfigs.configNames(Kafka_2_4_0).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_5_1 => LogkafkaNewConfigs.configNames(Kafka_2_4_1).map(n => (n,LKConfig(n,None))).toMap
+      case Kafka_2_6_0 => LogkafkaNewConfigs.configNames(Kafka_2_4_0).map(n => (n,LKConfig(n,None))).toMap
     }
     val identityOption = li.identityMap.get(log_path)
     if (identityOption.isDefined) {

diff --git a/app/kafka/manager/utils/LogkafkaNewConfigs.scala b/app/kafka/manager/utils/LogkafkaNewConfigs.scala
@@ -44,11 +44,11 @@ object LogkafkaNewConfigs {
     Kafka_2_2_2 -> logkafka82.LogConfig,
     Kafka_2_3_0 -> logkafka82.LogConfig,
     Kafka_2_3_1 -> logkafka82.LogConfig,
-    Kafka_2_4_0 -> two40.LogConfig,
-    Kafka_2_4_1 -> two40.LogConfig,
-    Kafka_2_5_0 -> two40.LogConfig,
-    Kafka_2_5_1 -> two40.LogConfig,
-    Kafka_2_6_0 -> two40.LogConfig
+    Kafka_2_4_0 -> logkafka82.LogConfig,
+    Kafka_2_4_1 -> logkafka82.LogConfig,
+    Kafka_2_5_0 -> logkafka82.LogConfig,
+    Kafka_2_5_1 -> logkafka82.LogConfig,
+    Kafka_2_6_0 -> logkafka82.LogConfig
   )
 
   def configNames(version: KafkaVersion) : Set[String] = {