From 9f97d09051949dffef572873bdad4f10b1d336af Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 15 Mar 2025 18:34:15 +0100 Subject: [PATCH] 2. Schritt Live-Umbau: Worker-Thread --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java index f5b79a04..1d9453b3 100644 --- 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 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(); } -- 2.39.5