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
index 7c06acdc5f..ed85984fc8 100644
--- 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);