1 package de.juplo.kafka;
3 import org.junit.jupiter.api.Test;
4 import org.springframework.beans.factory.annotation.Autowired;
5 import org.springframework.boot.test.autoconfigure.data.mongo.AutoConfigureDataMongo;
6 import org.springframework.boot.test.context.SpringBootTest;
7 import org.springframework.boot.test.web.client.TestRestTemplate;
8 import org.springframework.boot.test.web.server.LocalServerPort;
9 import org.springframework.kafka.test.context.EmbeddedKafka;
11 import static de.juplo.kafka.ApplicationIT.TOPIC;
15 webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
17 "consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
18 "consumer.topic=" + TOPIC,
19 "spring.mongodb.embedded.version=4.4.13" })
20 @EmbeddedKafka(topics = TOPIC)
21 @AutoConfigureDataMongo
22 public class ApplicationIT
24 public static final String TOPIC = "FOO";
30 private TestRestTemplate restTemplate;
35 public void testApplicationStartup()
37 restTemplate.getForObject(
38 "http://localhost:" + port + "/actuator/health",