From 9ca5acab1d4b1a7b6970349a89a6e434f1e1dae0 Mon Sep 17 00:00:00 2001
From: "A.Anikeev" <A.Anikeev@alfacapital.ru>
Date: Fri, 6 Jun 2025 20:19:13 +0300
Subject: [PATCH] feat: Add configuration properties to StreamKafkaEmbedded

---
 .../adven27/env/mq/kafka/embedded/StreamKafkaEmbedded.kt      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/env-mq-kafka-embedded/src/main/java/io/github/adven27/env/mq/kafka/embedded/StreamKafkaEmbedded.kt b/env-mq-kafka-embedded/src/main/java/io/github/adven27/env/mq/kafka/embedded/StreamKafkaEmbedded.kt
index 988cf0e..6726c35 100644
--- a/env-mq-kafka-embedded/src/main/java/io/github/adven27/env/mq/kafka/embedded/StreamKafkaEmbedded.kt
+++ b/env-mq-kafka-embedded/src/main/java/io/github/adven27/env/mq/kafka/embedded/StreamKafkaEmbedded.kt
@@ -1,14 +1,16 @@
 package io.github.adven27.env.mq.kafka.embedded
 
 import io.github.adven27.env.core.Environment.Companion.propagateToSystemProperties
+import io.github.adven27.env.core.ExternalSystem
 
 @Suppress("unused")
 open class StreamKafkaEmbedded @JvmOverloads constructor(
+    private val original: EmbeddedKafkaSystem,
     val topicSource: String = "in",
     val topicSink: String = "out",
     val topicDlq: String = "dlq",
     val group: String = "group"
-) : EmbeddedKafkaSystem() {
+) : ExternalSystem by original {
 
     private val properties =
         mapOf(