X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FSimpleConsumer.java;h=e9ce220ef33aeae424b3b6cbacc16a255e6af6ea;hb=refs%2Ftags%2Fspring%2Fspring-consumer--kafkalistener--vorlage---2023-06-signal;hp=fe0479f1a133dbc42466befb2f1fe4e056b3881b;hpb=ea9b7c9f5e35fa19dc8ad20cdb2790841da8d3db;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 fe0479f..e9ce220 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -17,17 +17,11 @@ public class SimpleConsumer
   private String id;
   private long consumed = 0;
 
-  @KafkaListener(topics = "${simple.consumer.topic}")
   private void handleRecord(
-    @Header(KafkaHeaders.RECEIVED_TOPIC)
     String topic,
-    @Header(KafkaHeaders.RECEIVED_PARTITION_ID)
     Integer partition,
-    @Header(KafkaHeaders.OFFSET)
     Long offset,
-    @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY)
     String key,
-    @Payload
     String value)
   {
     consumed++;