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 930717c91c4d1fe738ad7bd0262d5bfe414e11a8..5e0c3a71a758a28af5195425794188f3805023e3 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -73,11 +73,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());