X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationRecordHandler.java;h=5f2a201daa5bb0382bcce8aeeabfbf2e37bc4162;hb=48271d5fd1dbab2dc71d1490e6826048eb0716e2;hp=8431a53d91993edce5ea14a566871da75a80b22d;hpb=3ec888b859823d2e44af299d39da201b8a507ac8;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
index 8431a53..5f2a201 100644
--- a/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
+++ b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java
@@ -22,11 +22,7 @@ public class ApplicationRecordHandler implements RecordHandler<String, Integer>
     String key = record.key();
     int number = record.value();
 
-    for (int i = 1; i <= number; i++)
-    {
-      send(key, new AddNumberMessage(number, i));
-    }
-    send(key, new CalculateSumMessage(number));
+    // TODO: JSON-Nachrichten verschicken
   }
 
   private void send(String key, Object value)