From: Kai Moritz <kai@juplo.de>
Date: Mon, 7 Apr 2025 19:31:50 +0000 (+0200)
Subject: GRÜN: Erwartungen für existierende Offsets definiert
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b9b2f0f8777b37f52e9cb6eb0e9a88bab7b0f232;p=demos%2Fkafka%2Ftraining

GRÜN: Erwartungen für existierende Offsets definiert
---

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index d2a2242..c70d705 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -55,6 +55,23 @@ public class ApplicationTests
     assertThat(JsonPath.parse(response.getBody()).read("$.status", String.class)).isEqualTo("UP");
   }
 
+  @DisplayName("Existing offset")
+  @ParameterizedTest(name = "partition: {0}")
+  @FieldSource("PARTITIONS")
+  void testExistingOffset(int partition) throws Exception
+  {
+    String key = Integer.toString(partition);
+    String value = "Hallo Welt! -- " + partition;
+    RecordMetadata recordMetadata = send(partition, key, value);
+    ResponseEntity<String> response = restTemplate.getForEntity(
+      "/{partition}/{offset}",
+      String.class,
+      recordMetadata.partition(),
+      recordMetadata.offset());
+    assertThat(response.getStatusCode()).isEqualTo(HttpStatusCode.valueOf(HttpStatus.OK.value()));
+    assertThat(response.getBody()).isEqualTo(value);
+  }
+
   @DisplayName("Not yet existing offset")
   @ParameterizedTest(name = "partition: {0}")
   @FieldSource("PARTITIONS")