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.context.SpringBootTest;
6 import org.springframework.boot.test.web.client.TestRestTemplate;
7 import org.springframework.boot.test.web.server.LocalServerPort;
8 import org.springframework.kafka.test.context.EmbeddedKafka;
10 import static de.juplo.kafka.ApplicationIT.TOPIC;
14 webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
16 "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
17 "simple.consumer.topic=" + TOPIC })
18 @EmbeddedKafka(topics = TOPIC)
19 public class ApplicationIT
21 public static final String TOPIC = "FOO";
27 private TestRestTemplate restTemplate;
32 public void testApplicationStartup()
34 restTemplate.getForObject(
35 "http://localhost:" + port + "/actuator/health",