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