X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderController.java;h=c9d2109b4aaf43f165b4cdd0bf20f374496d0e06;hb=22615ba45bd7697e041eb10f88166cd2074de305;hp=f7e32e22e94853cd74a3fc13836976f6e0de1399;hpb=b185f168c230e65878ed4c99fc69229f356c41da;p=demos%2Fkafka%2Fwordcount diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java index f7e32e2..c9d2109 100644 --- a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java +++ b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java @@ -18,10 +18,12 @@ import jakarta.validation.constraints.NotEmpty; public class RecorderController { private final String topic; - private final KafkaProducer producer; + private final KafkaProducer producer; - public RecorderController(RecorderApplicationProperties properties, KafkaProducer producer) + public RecorderController( + RecorderApplicationProperties properties, + KafkaProducer producer) { this.topic = properties.getTopic(); this.producer = producer; @@ -44,7 +46,11 @@ public class RecorderController { DeferredResult> result = new DeferredResult<>(); - ProducerRecord record = new ProducerRecord<>(topic, username, sentence); + ProducerRecord record = new ProducerRecord<>( + topic, + username, + Recording.of(username, sentence)); + producer.send(record, (metadata, exception) -> { if (metadata != null)