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: spring/spring-consumer--json--vorlage--2025-04-signal-spickzettel
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fspring%2Fspring-consumer--json--vorlage;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 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);