+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",
+ })