X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FSplitterApplicationIT.java;h=92dfd1076ee068763826f56d17e2622cba57ac13;hb=a41c63a03ef29ddc081c58f2b4e73fa27fb2316b;hp=3fa5851f061bad65b88c5e38e9f591fde26d8ab0;hpb=5dade68933e284e71667e0bea4ac578d2ec3f1d6;p=demos%2Fkafka%2Fwordcount diff --git a/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java index 3fa5851..92dfd10 100644 --- a/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java +++ b/src/test/java/de/juplo/kafka/wordcount/splitter/SplitterApplicationIT.java @@ -17,7 +17,7 @@ import org.springframework.util.MultiValueMap; import java.time.Duration; -import static de.juplo.kafka.wordcount.splitter.SplitterApplicationTests.*; +import static de.juplo.kafka.wordcount.splitter.SplitterApplicationIT.*; import static org.assertj.core.api.Assertions.assertThat; import static org.awaitility.Awaitility.*; @@ -30,7 +30,7 @@ import static org.awaitility.Awaitility.*; "juplo.wordcount.splitter.output-topic=" + TOPIC_OUT }) @EmbeddedKafka(topics = { TOPIC_IN, TOPIC_OUT }, partitions = PARTITIONS) @Slf4j -public class SplitterApplicationTests +public class SplitterApplicationIT { public final static String TOPIC_IN = "in"; public final static String TOPIC_OUT = "out";