fix(kafka-runner): prevent first startup error on topic creation

kestra-io · Feb 18, 2022 · 6b23cc1 · 6b23cc1
1 parent 3b83ef7
commit 6b23cc1
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/runner-kafka/src/main/java/io/kestra/runner/kafka/services/KafkaAdminService.java b/runner-kafka/src/main/java/io/kestra/runner/kafka/services/KafkaAdminService.java
@@ -145,9 +145,10 @@ public void createIfNotExist(TopicsConfig topicConfig) {
                         }}).all().get();
 
                     log.info("Topic Config '{}' updated", newTopic.name());
-                } catch (TopicExistsException ignored) {
-                } catch (InterruptedException | ExecutionException e1) {
-                    throw new RuntimeException(e);
+                } catch (ExecutionException | InterruptedException exception) {
+                    if (!(exception.getCause() instanceof TopicExistsException)) {
+                        log.warn("Unable to update topic '{}'", newTopic.name(), exception);
+                    }
                 }
             } else {
                 throw new RuntimeException(e);