juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/DriverController.java

   1 package de.juplo.kafka;
   2
   3 import lombok.RequiredArgsConstructor;
   4 import org.springframework.http.HttpStatus;
   5 import org.springframework.web.bind.annotation.*;
   6
   7 import java.util.concurrent.ExecutionException;
   8
   9
  10 @RestController
  11 @RequiredArgsConstructor
  12 public class DriverController
  13 {
  14   private final EndlessConsumer consumer;
  15
  16
  17   @PostMapping("start")
  18   public void start()
  19   {
  20     consumer.start();
  21   }
  22
  23   @PostMapping("stop")
  24   public void stop() throws ExecutionException, InterruptedException
  25   {
  26     consumer.stop();
  27   }
  28
  29
  30   @ExceptionHandler
  31   @ResponseStatus(HttpStatus.BAD_REQUEST)
  32   public ErrorResponse illegalStateException(IllegalStateException e)
  33   {
  34     return new ErrorResponse(e.getMessage(), HttpStatus.BAD_REQUEST.value());
  35   }
  36 }