From 70d096df57791182d070c34be0aae05695336529 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 14 Mar 2025 10:34:30 +0100
Subject: [PATCH] =?utf8?q?Log-Meldung=20f=C3=BCr=20das=20Queuing=20der=20N?=
 =?utf8?q?achricht=20erg=C3=A4nzt?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../java/de/juplo/kafka/ExampleProducer.java   | 18 ++++++++++++++----
 1 file changed, 14 insertions(+), 4 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index c81d3bf7..14b7cbc1 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
     );
   }
 
-- 
2.39.5