Fix for scala 2.12

TouK · Oct 30, 2024 · 17b9df4 · 17b9df4
1 parent 515a8ee
commit 17b9df4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...in/scala/pl/touk/nussknacker/engine/schemedkafka/KafkaUniversalComponentTransformer.scala b/...in/scala/pl/touk/nussknacker/engine/schemedkafka/KafkaUniversalComponentTransformer.scala
@@ -77,7 +77,9 @@ abstract class KafkaUniversalComponentTransformer[T, TN <: TopicName: TopicValid
       // TODO: previously schemaRegistryClient made validation
       case Some(topicsFromKafka) =>
         // For test purposes mostly
-        topicSelectionStrategy.getTopics(schemaRegistryClient).map(_.appendedAll(topicsFromKafka).distinct)
+        topicSelectionStrategy
+          .getTopics(schemaRegistryClient)
+          .map(fromRegistry => (fromRegistry ++ topicsFromKafka).distinct)
       case None => topicSelectionStrategy.getTopics(schemaRegistryClient)
     }