From b9b2f0f8777b37f52e9cb6eb0e9a88bab7b0f232 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 7 Apr 2025 21:31:50 +0200
Subject: [PATCH] =?utf8?q?GR=C3=9CN:=20Erwartungen=20f=C3=BCr=20existieren?=
 =?utf8?q?de=20Offsets=20definiert?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../java/de/juplo/kafka/ApplicationTests.java   | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

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")
-- 
2.20.1