1 package de.juplo.kafka.wordcount.splitter;
3 import org.junit.jupiter.api.Test;
4 import org.springframework.beans.factory.annotation.Autowired;
5 import org.springframework.boot.test.context.SpringBootTest;
6 import org.springframework.kafka.test.context.EmbeddedKafka;
8 import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_IN;
9 import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_OUT;
14 "juplo.wordcount.splitter.bootstrap-server=${spring.embedded.kafka.brokers}",
15 "juplo.wordcount.splitter.input-topic=" + TOPIC_IN,
16 "juplo.wordcount.splitter.output-topic=" + TOPIC_OUT,
19 topics = { TOPIC_IN, TOPIC_OUT },
21 "transaction.state.log.replication.factor=1",
22 "transaction.state.log.min.isr=1",
24 class ApplicationTests
26 final static String TOPIC_IN = "in";
27 final static String TOPIC_OUT = "out";
30 SplitterStreamProcessor splitter;