diff --git a/app/controllers/Logkafka.scala b/app/controllers/Logkafka.scala index 2c7611571..3602fb85c 100644 --- 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 index 188c81651..0782169df 100644 --- 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] = {