X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationConfiguration.java;h=58f44faba9bc133788592e2c35765adb27fafde2;hb=b9ca34cf63146e9ae5e72a8722a92f17615586d2;hp=6e0445337aea5c641bc46495f4ccaaa66bd2bbf7;hpb=f9890a95d6672e1847e1d9f53a76c95ade877a9b;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 6e04453..58f44fa 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -20,16 +20,12 @@ public class ApplicationConfiguration
       KafkaConsumer<String, String> kafkaConsumer,
       ApplicationProperties properties)
   {
-    EndlessConsumer consumer =
+    return
         new EndlessConsumer(
             Executors.newFixedThreadPool(1),
             properties.getClientId(),
             properties.getTopic(),
             kafkaConsumer);
-
-    consumer.start();
-
-    return consumer;
   }
 
   @Bean(destroyMethod = "close")