From: Kai Moritz <kai@juplo.de>
Date: Wed, 5 Jun 2024 21:02:25 +0000 (+0200)
Subject: recorder: 1.2.0 - Fixed a bug (error-detection) in `RecorderController`
X-Git-Tag: recorder-1.2.0
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=b06e6649f54c4ab58cea812b96301dadbbd23b23;p=demos%2Fkafka%2Fwordcount

recorder: 1.2.0 - Fixed a bug (error-detection) in `RecorderController`
---

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 8df5242..e76d24c 100644
--- a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java
+++ b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java
@@ -53,7 +53,7 @@ public class RecorderController
 
     producer.send(record, (metadata, exception) ->
     {
-      if (metadata != null)
+      if (exception == null)
       {
         result.setResult(
             ResponseEntity.ok(RecordingResult.of(