lazy val

Author: jedrz

engine/flink/schemed-kafka-components-utils/src/test/scala/pl/touk/nussknacker/engine/schemedkafka/source/flink/TopicSelectionStrategySpec.scala

@@ -54,7 +54,7 @@ class TopicSelectionStrategySpec extends KafkaAvroSpecMixin with KafkaAvroSource
       testModelConfig,
       new FlinkKafkaSourceImplFactory(None)
     ) {
-      override def topicSelectionStrategy =
+      override lazy val topicSelectionStrategy =
         new TopicsMatchingPatternWithExistingSubjectsSelectionStrategy(Pattern.compile("test-.*"), confluentClient)
     }
   }

utils/schemed-kafka-components-utils/src/main/scala/pl/touk/nussknacker/engine/schemedkafka/KafkaUniversalComponentTransformer.scala

@@ -51,7 +51,7 @@ abstract class KafkaUniversalComponentTransformer[T, TN <: TopicName: TopicValid
 
   @transient protected lazy val cachedTopicsExistenceValidator = new CachedTopicsExistenceValidator(kafkaConfig)
 
-  protected def topicSelectionStrategy: TopicSelectionStrategy = {
+  protected lazy val topicSelectionStrategy: TopicSelectionStrategy = {
     if (kafkaConfig.topicsWithoutSchemaConfig.showTopicsWithoutSchema) {
       new AllNonHiddenTopicsSelectionStrategy(schemaRegistryClient, kafkaConfig)
     } else {