recorder: 1.2.0 - Fixed a bug (error-detection) in `RecorderController` recorder-1.2.0
authorKai Moritz <kai@juplo.de>
Wed, 5 Jun 2024 21:02:25 +0000 (23:02 +0200)
committerKai Moritz <kai@juplo.de>
Thu, 6 Jun 2024 18:57:34 +0000 (20:57 +0200)
src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java

index 8df5242..e76d24c 100644 (file)
@@ -53,7 +53,7 @@ public class RecorderController
 
     producer.send(record, (metadata, exception) ->
     {
-      if (metadata != null)
+      if (exception == null)
       {
         result.setResult(
             ResponseEntity.ok(RecordingResult.of(