recorder: 1.2.2 - RocksDB does nor work in Alpine-Linux

[demos/kafka/wordcount] / src / main / java / de / juplo / kafka / wordcount / recorder / RecorderController.java

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 (file)
--- 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(