From: Kai Moritz <kai@juplo.de>
Date: Fri, 2 Dec 2022 18:55:04 +0000 (+0100)
Subject: Hinweise ergänzt, weil sonst nicht klar war, was zu tun ist
X-Git-Tag: rest-producer--json--vorlage~1
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=399edbf556a7e87f5111fb068491562f6fd4c6f2;p=demos%2Fkafka%2Ftraining

Hinweise ergänzt, weil sonst nicht klar war, was zu tun ist
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index f1d773e..de7d0c4 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -40,7 +40,7 @@ public class ApplicationConfiguration
     props.put("linger.ms", properties.getLingerMs());
     props.put("compression.type", properties.getCompressionType());
     props.put("key.serializer", StringSerializer.class.getName());
-    props.put("value.serializer", IntegerSerializer.class.getName());
+    props.put("value.serializer", IntegerSerializer.class.getName()); // TODO: JsonSerializer
 
     return new KafkaProducer<>(props);
   }
diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index 2e0da97..90dd2ce 100644
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -30,6 +30,9 @@ public class RestProducer
       @RequestHeader(name = "X-id", required = false) Long correlationId,
       @RequestBody Integer number)
   {
+    // TODO: Wenn anstatt der Zahl "number" #number Nachrichten versendet
+    // werden muss der Zähler der folgenden Hilfsklasse entsprechend von
+    // 1 auf number angepasst werden!
     ResultRecorder result = new ResultRecorder(1);
 
     send(key, number, correlationId, result);