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.RestController;
7 import java.util.concurrent.ExecutionException;
11 @RequiredArgsConstructor
12 public class SeekController
14 private final Consumer consumer;
24 public void stop() throws ExecutionException, InterruptedException