From 0cbb66ac7826c9e7f05b3ce16d470814aae24392 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 12 Nov 2022 23:10:09 +0100
Subject: [PATCH] Vorlage

---
 src/main/java/de/juplo/kafka/SimpleConsumer.java | 6 ------
 1 file changed, 6 deletions(-)

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++;
-- 
2.20.1