Update nebula-dsl/src/main/kotlin/com/orbitalhq/nebula/kafka/KafkaExecutor.kt

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: martypitt

nebula-dsl/src/main/kotlin/com/orbitalhq/nebula/kafka/KafkaExecutor.kt

@@ -157,8 +157,10 @@ class KafkaExecutor(private val config: KafkaConfig) : InfrastructureComponent<K
                     val result = adminClient.createTopics(topicConfigs)
                     result.all().get(30, TimeUnit.SECONDS) // Wait for completion with timeout
                     logger.info { "Created topics: ${topicConfigs.map { "${it.name()}(${it.numPartitions()} partitions)" }}" }
+                } catch (e: TopicExistsException) {
+                    logger.warn(e) { "Some topics already exist: ${e.message}" }
                 } catch (e: Exception) {
-                    logger.warn(e) { "Failed to create some topics (they may already exist): ${e.message}" }
+                    logger.error(e) { "Failed to create topics due to unexpected error: ${e.message}" }
                 }
             }
         }