splitter: 1.0.0-vanilla-kafka - Fixed the test "Context Loads"

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / splitter / ApplicationTests.java

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 (file)
--- 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();
        }
 }