X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FApplicationTests.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FApplicationTests.java;h=5e79b87f51f7d6a5f26aadab354d95afaeeb3fa6;hb=723ec6bbc03aaa4f552fd3a27986c120ea46fccf;hp=77266a94d30e7b43c66afe9da15131720ae2ea4c;hpb=89d429ad1ad583fb9d52d51ed37cd5a885a9c8c3;p=demos%2Fkafka%2Fwordcount

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 77266a9..5e79b87 100644
--- a/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
@@ -1,13 +1,37 @@
 package de.juplo.kafka.wordcount.splitter;
 
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.kafka.test.context.EmbeddedKafka;
 
-@SpringBootTest
+import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_IN;
+import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_OUT;
+
+
+@SpringBootTest(
+		properties = {
+				"juplo.wordcount.splitter.bootstrap-server=${spring.embedded.kafka.brokers}",
+				"juplo.wordcount.splitter.input-topic=" + TOPIC_IN,
+				"juplo.wordcount.splitter.output-topic=" + TOPIC_OUT,
+		})
+@EmbeddedKafka(
+		topics = { TOPIC_IN, TOPIC_OUT },
+		brokerProperties = {
+				"transaction.state.log.replication.factor=1",
+				"transaction.state.log.min.isr=1",
+		})
 class ApplicationTests
 {
+	final static String TOPIC_IN = "in";
+	final static String TOPIC_OUT = "out";
+
+	@Autowired
+	SplitterStreamProcessor splitter;
+
 	@Test
 	void contextLoads()
 	{
+		splitter.stop();
 	}
 }