WIP

[demos/kafka/seek] / src / main / java / de / juplo / kafka / seek / SeekController.java

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