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