From: Kai Moritz <kai@juplo.de>
Date: Sat, 1 Mar 2025 21:02:24 +0000 (+0100)
Subject: `ExampleConsumer` auf Basis von `@KafkaListener` über Generics typisiert
X-Git-Tag: spring/spring-consumer--kafkalistener--long--2025-03-18--19-42~1
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=551cc278cae09f1fd1e1f756722f0f8d69762c78;p=demos%2Fkafka%2Ftraining

`ExampleConsumer` auf Basis von `@KafkaListener` über Generics typisiert
---

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);