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 (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 2e0da97..90dd2ce 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);