X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;h=53bd11205692d125acfbbde85613150cb65411bf;hb=28861eab2d4da8a0594a115de989ffeb90b05cd4;hp=64d5176a3fff1428540a182b548d6a34b995e218;hpb=ae796c9e9e4ec5c86853aa9b100d0cfe4deeda3c;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 64d5176..53bd112 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -6,7 +6,6 @@ import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.common.errors.WakeupException; -import org.springframework.core.task.TaskExecutor; import java.time.Duration; import java.util.Arrays; @@ -16,7 +15,6 @@ import java.util.Arrays; @RequiredArgsConstructor public class SimpleConsumer implements Runnable { - private final TaskExecutor taskExecutor; private final String id; private final String topic; private final Consumer consumer; @@ -24,11 +22,6 @@ public class SimpleConsumer implements Runnable private long consumed = 0; - public void start() - { - taskExecutor.execute(this); - } - @Override public void run() {