From: Kai Moritz <kai@juplo.de>
Date: Thu, 30 Jun 2022 15:41:08 +0000 (+0200)
Subject: WIP
X-Git-Tag: wip-test-vanilla-kafka
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ed2f69af38c2fbdd5c76e4f4902129bb5af3c5bf;p=demos%2Fkafka%2Fwordcount

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 9165180..36154ea 100644
--- 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 },