X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationIT.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationIT.java;h=cded0ee30cd9a0d70fa3497518f37bca488ad2d1;hb=2768e0f97c441ade5ce8ff371aa590fdc3cfd6c6;hp=4c149cc289b553504608bcd54f62cff2693cd362;hpb=b4b08b184fbe583b45c85b9b9c5622e4c1ac5de5;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationIT.java b/src/test/java/de/juplo/kafka/ApplicationIT.java
index 4c149cc..cded0ee 100644
--- a/src/test/java/de/juplo/kafka/ApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/ApplicationIT.java
@@ -1,14 +1,18 @@
 package de.juplo.kafka;
 
 import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.autoconfigure.data.mongo.AutoConfigureDataMongo;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.web.client.TestRestTemplate;
+import org.springframework.boot.test.web.server.LocalServerPort;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 
 import static de.juplo.kafka.ApplicationTests.TOPIC;
 
 
 @SpringBootTest(
+    webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
     properties = {
         "consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
         "consumer.topic=" + TOPIC,
@@ -19,7 +23,21 @@ public class ApplicationIT
 {
   public static final String TOPIC = "FOO";
 
+  @LocalServerPort
+  private int port;
+
+  @Autowired
+  private TestRestTemplate restTemplate;
+
+
 
   @Test
-  public void testApplicationStartup() {}
+  public void testApplicationStartup()
+  {
+    restTemplate.getForObject(
+        "http://localhost:" + port + "/actuator/health",
+        String.class
+        )
+        .contains("UP");
+  }
 }