WIP

diff --git a/pom.xml b/pom.xml
index f413864..7e84360 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -56,6 +56,11 @@
                        <artifactId>spring-boot-starter-test</artifactId>
                        <scope>test</scope>
                </dependency>
+               <dependency>
+                       <groupId>org.springframework.kafka</groupId>
+                       <artifactId>spring-kafka</artifactId>
+                       <scope>test</scope>
+               </dependency>
                <dependency>
                        <groupId>org.springframework.kafka</groupId>
                        <artifactId>spring-kafka-test</artifactId>

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 f02762b..274efa9 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java
@@ -3,7 +3,14 @@ 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.boot.test.util.TestPropertyValues;
+import org.springframework.context.ApplicationContextInitializer;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.kafka.test.EmbeddedKafkaBroker;
 import org.springframework.kafka.test.context.EmbeddedKafka;
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
 
 import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_IN;
 import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_OUT;
@@ -28,10 +35,27 @@ class ApplicationTests
 
        @Autowired
        SplitterStreamProcessor splitter;
+       @Autowired
+       EmbeddedKafkaBroker embeddedKafkaBroker;
+       @Autowired
+       KafkaTemplate<String, String> kafkaTemplate;
 
        @Test
        void contextLoads()
        {
                splitter.stop();
        }
+
+       @Test
+       void split()
+       {
+               kafkaTemplate.send(TOPIC_IN, "Hello World!");
+       }
+
+
+       @DynamicPropertySource
+       static void registerProperties(DynamicPropertyRegistry registry)
+       {
+               registry.add("")
+       }
 }