Vorlage

[demos/kafka/training] / src / main / java / de / juplo / kafka / ApplicationRecordHandler.java

diff --git a/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
index a3b849e..205d3a1 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
+++ b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
@@ -40,15 +40,9 @@ public class ApplicationRecordHandler
     results.addResults(partition, user, result);
   }
 
-  @KafkaListener(
-      id = "${spring.kafka.consumer.group-id}",
-      topics = "${sumup.adder.topic}")
   public void accept(
-      @Header(KafkaHeaders.RECEIVED_PARTITION_ID)
       Integer partition,
-      @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY)
       String user,
-      @Payload
       Message message)
   {
     switch(message.getType())