From: Kai Moritz <kai@juplo.de>
Date: Sat, 5 Apr 2025 17:58:08 +0000 (+0200)
Subject: ROT: Verhalten beim Abrufen eines nicht existierenden Offsets definiert
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=7e3697101ae7ef8f9f16c6700b4b860b4ca485ce;p=demos%2Fkafka%2Ftraining

ROT: Verhalten beim Abrufen eines nicht existierenden Offsets definiert
---

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 0a51022..ba6c4af 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -1,6 +1,7 @@
 package de.juplo.kafka;
 
 import com.jayway.jsonpath.JsonPath;
+import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
@@ -25,6 +26,7 @@ import static org.assertj.core.api.Assertions.assertThat;
 @EmbeddedKafka(topics = TOPIC, partitions = NUM_PARTITIONS)
 public class ApplicationTests
 {
+  @DisplayName("Application startup")
   @Test
   public void testApplicationStartup()
   {
@@ -33,6 +35,14 @@ public class ApplicationTests
     assertThat(JsonPath.parse(response.getBody()).read("$.status", String.class)).isEqualTo("UP");
   }
 
+  @DisplayName("Not yet existing offset")
+  @Test
+  void testNotYetExistingOffset()
+  {
+    ResponseEntity<String> response = restTemplate.getForEntity("/1/66666666666", String.class);
+    assertThat(response.getStatusCode()).isEqualTo(HttpStatusCode.valueOf(HttpStatus.NOT_FOUND.value()));
+  }
+
 
   static final String TOPIC = "ExampleConsumerTest_TEST";
   static final int NUM_PARTITIONS = 7;