From b06e6649f54c4ab58cea812b96301dadbbd23b23 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 5 Jun 2024 23:02:25 +0200 Subject: [PATCH] recorder: 1.2.0 - Fixed a bug (error-detection) in `RecorderController` --- .../de/juplo/kafka/wordcount/recorder/RecorderController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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( -- 2.20.1