From: Kai Moritz <kai@juplo.de>
Date: Sat, 12 Apr 2025 21:43:12 +0000 (+0200)
Subject: Hinweise für JSON-Übung entfernt, da hier zuvor mit dem Umbau eingestiegen wird
X-Git-Tag: springkafka/spring-consumer--json--vorlage--2026-03-21--smartlifecycle-only
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=8875c48d0d4039b8764edaff76b70aaf9d9c6578;p=demos%2Fkafka%2Ftraining

Hinweise für JSON-Übung entfernt, da hier zuvor mit dem Umbau eingestiegen wird
---

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