Hinweise für JSON-Übung entfernt, da hier zuvor mit dem Umbau eingestiegen wird spring/spring-consumer--json--vorlage spring/spring-consumer--json--vorlage--2025-04-signal-spickzettel spring/spring-consumer--json--vorlage--2025-05-lvm spring/spring-consumer--json--vorlage--2025-05-lvm--spickzettel spring/spring-consumer--json--vorlage--2025-05-signal-spickzettel spring/spring-consumer--json--vorlage--2025-07-05
authorKai Moritz <kai@juplo.de>
Sat, 12 Apr 2025 21:43:12 +0000 (23:43 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 12 Apr 2025 22:00:27 +0000 (00:00 +0200)
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ExampleConsumer.java

index 3cadf3e..ea6b64e 100644 (file)
@@ -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);
   }
index 1d25f18..a83e213 100644 (file)
@@ -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);