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.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;
   9
  10 import static de.juplo.kafka.ApplicationIT.TOPIC;
  11
  12
  13 @SpringBootTest(
  14     webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
  15     properties = {
  16         "spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
  17         "simple.consumer.topic=" + TOPIC })
  18 @EmbeddedKafka(topics = TOPIC)
  19 public class ApplicationIT
  20 {
  21   public static final String TOPIC = "FOO";
  22
  23   @LocalServerPort
  24   private int port;
  25
  26   @Autowired
  27   private TestRestTemplate restTemplate;
  28
  29
  30
  31   @Test
  32   public void testApplicationStartup()
  33   {
  34     restTemplate.getForObject(
  35         "http://localhost:" + port + "/actuator/health",
  36         String.class
  37         )
  38         .contains("UP");
  39   }
  40 }