X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationRecordHandler.java;h=5f2a201daa5bb0382bcce8aeeabfbf2e37bc4162;hb=48271d5fd1dbab2dc71d1490e6826048eb0716e2;hp=eae009c84b73bb8ad07a33acd2aad3544443bfe1;hpb=a53845885ccfa90fb94dd7696762647a450c4394;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 eae009c..5f2a201 100644 --- a/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java +++ b/src/main/java/de/juplo/kafka/ApplicationRecordHandler.java @@ -11,7 +11,7 @@ import org.apache.kafka.clients.producer.ProducerRecord; @Slf4j public class ApplicationRecordHandler implements RecordHandler { - private final Producer producer; + private final Producer producer; private final String id; private final String topic; @@ -22,18 +22,14 @@ public class ApplicationRecordHandler implements RecordHandler String key = record.key(); int number = record.value(); - for (int i = 1; i <= number; i++) - { - send(key, Integer.toString(i)); - } - send(key, "CALCULATE"); + // TODO: JSON-Nachrichten verschicken } - private void send(String key, String value) + private void send(String key, Object value) { final long time = System.currentTimeMillis(); - final ProducerRecord record = new ProducerRecord<>( + final ProducerRecord record = new ProducerRecord<>( topic, // Topic key, // Key value // Value