From 2740f10000e1a60096b8b4cd7a0cb7cf42af72f1 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 12 Apr 2025 23:43:12 +0200
Subject: [PATCH] =?utf8?q?Hinweise=20f=C3=BCr=20JSON-=C3=9Cbung=20entfernt?=
 =?utf8?q?,=20da=20hier=20zuvor=20mit=20dem=20Umbau=20eingestiegen=20wird?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 5 ++---
 src/main/java/de/juplo/kafka/ExampleConsumer.java          | 7 +++++--
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 3cadf3e0..ea6b64ea 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -17,7 +17,7 @@ public class ApplicationConfiguration
 {
   @Bean
   public ExampleConsumer exampleConsumer(
-    Consumer<String, String> kafkaConsumer, // << TODO: Typisierung anpassen
+    Consumer<String, String> kafkaConsumer,
     ApplicationProperties properties,
     ConfigurableApplicationContext applicationContext)
   {
@@ -30,7 +30,6 @@ public class ApplicationConfiguration
   }
 
   @Bean(destroyMethod = "")
-  // TODO: Typisierung anpassen
   public KafkaConsumer<String, String> kafkaConsumer(ApplicationProperties properties)
   {
     Properties props = new Properties();
@@ -47,7 +46,7 @@ public class ApplicationConfiguration
     }
     props.put("metadata.max.age.ms", 5000); //  5 Sekunden
     props.put("key.deserializer", StringDeserializer.class.getName());
-    props.put("value.deserializer", StringDeserializer.class.getName()); // << TODO: Passende Strategie konfigurieren
+    props.put("value.deserializer", StringDeserializer.class.getName());
 
     return new KafkaConsumer<>(props);
   }
diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 1d25f187..a83e2136 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -15,7 +15,7 @@ public class ExampleConsumer implements Runnable
 {
   private final String id;
   private final String topic;
-  private final Consumer<String, String> consumer; // << TODO: Typisierung anpassen
+  private final Consumer<String, String> consumer;
   private final Thread workerThread;
   private final Runnable closeCallback;
 
@@ -50,7 +50,10 @@ public class ExampleConsumer implements Runnable
       while (true)
       {
         // TODO: Poll & Consume aus Ihrer bisherigen Implementierung
-        // TODO: Verarbeitung abhängig vom Typ der Nachricht auslösen
+
+        // FÜR EINE SPÄTERE ÜBUNG:
+        // Verarbeitung abhängig vom Typ der Nachricht auslösen
+        //
         // switch (value.getType())
         // {
         //   case ADD  -> addNumber((MessageAddNumber)value);
-- 
2.20.1