X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fseek;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fseek%2FSeekController.java;h=24cb6c11eded0ba45452e6fec72896c5a986e589;hp=9a96c4a42dee4939624ce916b9791f540b748814;hb=2022198b31ce426538388105dc26114ad393739b;hpb=7fa06f9b4d341fb34fec502ec4f18048231a43a7

diff --git a/src/main/java/de/juplo/kafka/seek/SeekController.java b/src/main/java/de/juplo/kafka/seek/SeekController.java
index 9a96c4a..24cb6c1 100644
--- a/src/main/java/de/juplo/kafka/seek/SeekController.java
+++ b/src/main/java/de/juplo/kafka/seek/SeekController.java
@@ -2,6 +2,7 @@ package de.juplo.kafka.seek;
 
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.concurrent.ExecutionException;
@@ -25,4 +26,11 @@ public class SeekController
   {
     consumer.stop();
   }
+
+
+  @PostMapping("seek")
+  public void seek(@RequestBody long offset)
+  {
+    consumer.seek(offset);
+  }
 }