X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;h=5305ceb94f1fcad1b29c9cb17bd3825d7c6ef8e3;hb=b059b0e509cca9a16ae209ade49c967a66201de9;hp=53bd11205692d125acfbbde85613150cb65411bf;hpb=7d270fa1c846f2cde38dcdda6f2111d032dbbc3e;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 53bd112..5305ceb 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -13,7 +13,7 @@ import java.util.Arrays;
 
 @Slf4j
 @RequiredArgsConstructor
-public class SimpleConsumer implements Runnable
+public class SimpleConsumer
 {
   private final String id;
   private final String topic;
@@ -22,7 +22,6 @@ public class SimpleConsumer implements Runnable
   private long consumed = 0;
 
 
-  @Override
   public void run()
   {
     try