From 35e92c786ef3e2023633bab1ad47340f0f23043c Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 2 Nov 2022 18:54:37 +0100 Subject: [PATCH] WIP --- src/main/java/de/juplo/kafka/SimpleConsumer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 040e24b..72dc36e 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -21,7 +21,6 @@ public class SimpleConsumer implements Runnable private final String topic; private final Consumer consumer; - private volatile boolean running = false; private long consumed = 0; @@ -31,7 +30,7 @@ public class SimpleConsumer implements Runnable try { log.info("{} - Subscribing to topic test", id); - consumer.subscribe(Arrays.asList("test")); + consumer.subscribe(Arrays.asList(topic)); running = true; while (true) -- 2.20.1