X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;h=fe0479f1a133dbc42466befb2f1fe4e056b3881b;hb=eb6234d2f2f6deceb46e94d5d019749879516aeb;hp=31c7e6b556df41c14ac9cc3e960ba31653ea01a3;hpb=17b25ab1fb29e6445a25dbc604f261322bdda0ec;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 31c7e6b..fe0479f 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -17,10 +17,7 @@ public class SimpleConsumer
   private String id;
   private long consumed = 0;
 
-  @KafkaListener(
-    id = "${spring.kafka.client-id}",
-    groupId = "${spring.kafka.consumer.group-id}",
-    topics = "${simple.consumer.topic}")
+  @KafkaListener(topics = "${simple.consumer.topic}")
   private void handleRecord(
     @Header(KafkaHeaders.RECEIVED_TOPIC)
     String topic,