juplo.de Git - demos/kafka/wordcount/blob - src/test/java/de/juplo/kafka/wordcount/splitter/ApplicationTests.java

   1 package de.juplo.kafka.wordcount.splitter;
   2
   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;
   7
   8 import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_IN;
   9 import static de.juplo.kafka.wordcount.splitter.ApplicationTests.TOPIC_OUT;
  10
  11
  12 @SpringBootTest(
  13                 properties = {
  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,
  17                 })
  18 @EmbeddedKafka(
  19                 topics = { TOPIC_IN, TOPIC_OUT },
  20                 brokerProperties = {
  21                                 "transaction.state.log.replication.factor=1",
  22                                 "transaction.state.log.min.isr=1",
  23                 })
  24 class ApplicationTests
  25 {
  26         final static String TOPIC_IN = "in";
  27         final static String TOPIC_OUT = "out";
  28
  29         @Autowired
  30         SplitterStreamProcessor splitter;
  31
  32         @Test
  33         void contextLoads()
  34         {
  35                 splitter.stop();
  36         }
  37 }