From 8875c48d0d4039b8764edaff76b70aaf9d9c6578 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 a73ff1af..a45c1505 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)
   {
@@ -29,7 +29,6 @@ public class ApplicationConfiguration
   }
 
   @Bean(destroyMethod = "")
-  // TODO: Typisierung anpassen
   public KafkaConsumer<String, String> kafkaConsumer(ApplicationProperties properties)
   {
     Properties props = new Properties();
@@ -46,7 +45,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 974d0f61..375a14a5 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -16,7 +16,7 @@ public class ExampleConsumer implements Runnable, SmartLifecycle
 {
   private final String id;
   private final String topic;
-  private final Consumer<String, String> consumer; // << TODO: Typisierung anpassen
+  private final Consumer<String, String> consumer;
 
   private Thread workerThread;
   private volatile boolean running = false;
@@ -58,7 +58,10 @@ public class ExampleConsumer implements Runnable, SmartLifecycle
       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.39.5