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 c81d3bf74ebc8894b98021e289444741d5aa25ed..14b7cbc11deb009fe1e346ef2e9874b4c8cdb47f 100644 (file)
--- 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
     );
   }