From: Kai Moritz <kai@juplo.de>
Date: Mon, 7 Apr 2025 21:18:58 +0000 (+0200)
Subject: Refacotr: Erzeugung der Testnachrichten überarbeitet
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=40d3d2e7a5364c7991519f471f97fab3ac8730a2;p=demos%2Fkafka%2Ftraining

Refacotr: Erzeugung der Testnachrichten überarbeitet
---

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());