1 package de.juplo.kafka.seek;
3 import lombok.RequiredArgsConstructor;
4 import org.springframework.web.bind.annotation.PostMapping;
5 import org.springframework.web.bind.annotation.RequestBody;
6 import org.springframework.web.bind.annotation.RestController;
8 import java.util.concurrent.ExecutionException;
12 @RequiredArgsConstructor
13 public class SeekController
15 private final Consumer consumer;
25 public void stop() throws ExecutionException, InterruptedException
32 public void seek(@RequestBody long offset)
34 consumer.seek(offset);