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;
12 webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
13 properties = "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}")
14 @EmbeddedKafka(topics = "out")
15 public class ApplicationTests
21 private TestRestTemplate restTemplate;
26 public void testApplicationStartup()
28 restTemplate.getForObject(
29 "http://localhost:" + port + "/actuator/health",