Kafka exception also caught and pass with empty list of topics from k…

…afka
TouK · Nov 28, 2024 · ce33666 · ce33666
1 parent f7e4dd4
commit ce33666
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...utils/src/main/scala/pl/touk/nussknacker/engine/schemedkafka/TopicSelectionStrategy.scala b/...utils/src/main/scala/pl/touk/nussknacker/engine/schemedkafka/TopicSelectionStrategy.scala
@@ -2,6 +2,7 @@ package pl.touk.nussknacker.engine.schemedkafka
 
 import cats.data.Validated
 import org.apache.kafka.clients.admin.ListTopicsOptions
+import org.apache.kafka.common.KafkaException
 import org.apache.kafka.common.errors.TimeoutException
 import pl.touk.nussknacker.engine.kafka.{KafkaConfig, KafkaUtils, UnspecializedTopicName}
 import pl.touk.nussknacker.engine.schemedkafka.schemaregistry.{SchemaRegistryClient, SchemaRegistryError}
@@ -57,6 +58,8 @@ class AllNonHiddenTopicsSelectionStrategy extends TopicSelectionStrategy {
             case _: TimeoutException => List.empty
             case _                   => throw err
           }
+        case _: KafkaException =>
+          List.empty
       }
     }