From 551cc278cae09f1fd1e1f756722f0f8d69762c78 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 1 Mar 2025 22:02:24 +0100
Subject: [PATCH] =?utf8?q?`ExampleConsumer`=20auf=20Basis=20von=20`@KafkaL?=
 =?utf8?q?istener`=20=C3=BCber=20Generics=20typisiert?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/ExampleConsumer.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 5894a103..6618004a 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -12,7 +12,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class ExampleConsumer
+public class ExampleConsumer<K, V>
 {
   @Value("${spring.kafka.client-id}")
   private String id;
@@ -27,9 +27,9 @@ public class ExampleConsumer
     @Header(KafkaHeaders.OFFSET)
     Long offset,
     @Header(KafkaHeaders.RECEIVED_KEY)
-    String key,
+    K key,
     @Payload
-    String value)
+    V value)
   {
     handleRecord(topic, partition, offset, key, value);
   }
@@ -38,8 +38,8 @@ public class ExampleConsumer
     String topic,
     Integer partition,
     Long offset,
-    String key,
-    String value)
+    K key,
+    V value)
   {
     consumed++;
     log.info("{} - partition={}-{}, offset={}: {}={}", id, topic, partition, offset, key, value);
-- 
2.20.1