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 f1d773e31a27686f3b3313fdd175688d6e6e5a4e..de7d0c4dd67f6b40d31ea920ca84edde7507af86 100644 (file)
--- 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 2e0da977b0fccfd70ff2cc637ee61c5967a63800..90dd2ce19e0a64e26d481598c500f2fbd4ec2c45 100644 (file)
--- 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);