1 package de.juplo.kafka;
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;
8 import static de.juplo.kafka.ApplicationTests.TOPIC;
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
20 public static final String TOPIC = "FOO";
24 public void testApplicationStartup() {}