From: Kai Moritz <kai@juplo.de>
Date: Fri, 14 Mar 2025 09:34:30 +0000 (+0100)
Subject: Log-Meldung für das Queuing der Nachricht ergänzt
X-Git-Tag: grundlagen/simple-producer--completablefuture--2026-03--vor-branchumbenennung--springframework~5
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=c4f3eb06e54fb9c28fd7ae9d9859b1347b5862a5;p=demos%2Fkafka%2Ftraining

Log-Meldung für das Queuing der Nachricht ergänzt
---

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 60f30fc0..cb7ba1b1 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -9,6 +9,7 @@ import org.apache.kafka.common.serialization.StringSerializer;
 
 import java.util.Properties;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Future;
 
 
 @Slf4j
@@ -78,7 +79,16 @@ public class ExampleProducer
       {
         try
         {
-          return producer.send(record).get();
+          Future<RecordMetadata> result = producer.send(record);
+          long sendRequestQueued = System.currentTimeMillis();
+          log.trace(
+            "{} - Queued message {}={}, latency={}ms",
+            id,
+            key,
+            value,
+            sendRequestQueued - sendRequested
+          );
+          return result.get();
         }
         catch (Exception e)
         {
@@ -117,14 +127,14 @@ public class ExampleProducer
       }
     });
 
-    long sendRequestQueued = System.currentTimeMillis();
+    long queuingOfSendRequestScheduled = System.currentTimeMillis();
     produced++;
     log.trace(
-      "{} - Queued message {}={}, latency={}ms",
+      "{} - Scheduled queuing of message {}={}, latency={}ms",
       id,
       key,
       value,
-      sendRequestQueued - sendRequested
+      queuingOfSendRequestScheduled - sendRequested
     );
   }