juplo.de Git - demos/kafka/training/blob - src/test/java/de/juplo/kafka/ApplicationIT.java

   1 package de.juplo.kafka;
   2
   3 import org.junit.jupiter.api.Test;
   4 import org.springframework.boot.test.autoconfigure.data.mongo.AutoConfigureDataMongo;
   5 import org.springframework.boot.test.context.SpringBootTest;
   6 import org.springframework.kafka.test.context.EmbeddedKafka;
   7
   8 import static de.juplo.kafka.ApplicationTests.TOPIC;
   9
  10
  11 @SpringBootTest(
  12     properties = {
  13         "consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
  14         "consumer.topic=" + TOPIC,
  15         "spring.mongodb.embedded.version=4.4.13" })
  16 @EmbeddedKafka(topics = TOPIC)
  17 @AutoConfigureDataMongo
  18 public class ApplicationIT
  19 {
  20   public static final String TOPIC = "FOO";
  21
  22
  23   @Test
  24   public void testApplicationStartup() {}
  25 }