Springify: `start()`/`stop()`/`destroy()` in EndlessConsumer wiederbelebt

[demos/kafka/training] / src / main / java / de / juplo / kafka / DriverController.java

diff --git a/src/main/java/de/juplo/kafka/DriverController.java b/src/main/java/de/juplo/kafka/DriverController.java
index 8ca3e2a..480e7d1 100644 (file)
--- a/src/main/java/de/juplo/kafka/DriverController.java
+++ b/src/main/java/de/juplo/kafka/DriverController.java
@@ -17,14 +17,19 @@ import java.util.concurrent.ExecutionException;
 @RequiredArgsConstructor
 public class DriverController
 {
+  private final EndlessConsumer consumer;
+
+
   @PostMapping("start")
   public void start()
   {
+    consumer.start();
   }
 
   @PostMapping("stop")
-  public void stop() throws ExecutionException, InterruptedException
+  public void stop()
   {
+    consumer.stop();
   }
 
   @GetMapping("seen")