X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderController.java;h=e76d24c9125d0945325bf18487ae1b105bfd5670;hb=refs%2Fheads%2Frecorder;hp=c9d2109b4aaf43f165b4cdd0bf20f374496d0e06;hpb=22615ba45bd7697e041eb10f88166cd2074de305;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 c9d2109..e76d24c 100644
--- a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java
+++ b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java
@@ -18,12 +18,12 @@ import jakarta.validation.constraints.NotEmpty;
 public class RecorderController
 {
   private final String topic;
-  private final KafkaProducer<String, Recording> producer;
+  private final KafkaProducer<User, Recording> producer;
 
 
   public RecorderController(
       RecorderApplicationProperties properties,
-      KafkaProducer<String,Recording> producer)
+      KafkaProducer<User, Recording> producer)
   {
     this.topic = properties.getTopic();
     this.producer = producer;
@@ -46,14 +46,14 @@ public class RecorderController
   {
     DeferredResult<ResponseEntity<RecordingResult>> result = new DeferredResult<>();
 
-    ProducerRecord<String, Recording> record = new ProducerRecord<>(
+    ProducerRecord<User, Recording> record = new ProducerRecord<>(
         topic,
-        username,
+        User.of(username),
         Recording.of(username, sentence));
 
     producer.send(record, (metadata, exception) ->
     {
-      if (metadata != null)
+      if (exception == null)
       {
         result.setResult(
             ResponseEntity.ok(RecordingResult.of(