2. Schritt Live-Umbau: Worker-Thread

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index f5b79a045746ef60b10d7a959e814e1214d3a660..1d9453b331277dc0abbe8dbdcb11b3f9d8ea6835 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -16,6 +16,7 @@ public class ExampleConsumer implements Runnable
   private final String id;
   private final String topic;
   private final Consumer<String, String> consumer;
+  private final Thread workerThread;
 
   private long consumed = 0;
 
@@ -27,6 +28,9 @@ public class ExampleConsumer implements Runnable
     this.id = clientId;
     this.topic = topic;
     this.consumer = consumer;
+
+    workerThread = new Thread(this, "ExampleConsumer Worker-Thread");
+    workerThread.start();
   }