Endless Producer: a simple producer, implemented as Spring-Boot-App

[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
new file mode 100644 (file)
index 0000000..f8a287d
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/DriverController.java
@@ -0,0 +1,28 @@
+package de.juplo.kafka;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.concurrent.ExecutionException;
+
+
+@RestController
+@RequiredArgsConstructor
+public class DriverController
+{
+  private final EndlessProducer producer;
+
+
+  @PostMapping("start")
+  public void start()
+  {
+    producer.start();
+  }
+
+  @PostMapping("stop")
+  public void stop() throws ExecutionException, InterruptedException
+  {
+    producer.stop();
+  }
+}