From 40d3d2e7a5364c7991519f471f97fab3ac8730a2 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 7 Apr 2025 23:18:58 +0200
Subject: [PATCH] =?utf8?q?Refacotr:=20Erzeugung=20der=20Testnachrichten=20?=
 =?utf8?q?=C3=BCberarbeitet?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/test/java/de/juplo/kafka/ApplicationTests.java | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index f356ba1..76e5278 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -69,11 +69,22 @@ public class ApplicationTests
     SendResult<byte[], byte[]> result = send(partition);
 
     RecordMetadata recordMetadata = result.getRecordMetadata();
-    ResponseEntity<String> response = restTemplate.getForEntity(
+    ResponseEntity<String> response = fetchRecord(recordMetadata);
+    check(result, response);
+  }
+
+  private ResponseEntity<String> fetchRecord(RecordMetadata recordMetadata)
+  {
+    return restTemplate.getForEntity(
       "/{partition}/{offset}",
       String.class,
       recordMetadata.partition(),
       recordMetadata.offset());
+  }
+
+  private void check(SendResult<byte[], byte[]> result, ResponseEntity<String> response)
+  {
+    RecordMetadata recordMetadata = result.getRecordMetadata();
 
     String key = new String(result.getProducerRecord().key());
     String value = new String(result.getProducerRecord().value());
-- 
2.20.1