WIP

diff --git a/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java b/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
index 9165180c507f835b269aba3e94a1c6f75266ff66..36154eaab3d333eb415c2e6ba0150a44edda9a0f 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
@@ -13,9 +13,10 @@ import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_OUT;
 
 @SpringBootTest(
                properties = {
-                               "juplo.wordcount.splitter.bootstrap-server=${spring.embedded.kafka.brokers",
+                               "juplo.wordcount.splitter.bootstrap-server=${spring.embedded.kafka.brokers}",
                                "juplo.wordcount.splitter.input-topic=" + TOPIC_IN,
                                "juplo.wordcount.splitter.outtput-topic=" + TOPIC_OUT,
+                               "spring.kafka.bootstrap-servers=" + TOPIC_OUT,
                })
 @EmbeddedKafka(
                topics = { TOPIC_IN, TOPIC_OUT },