From: Kai Moritz <kai@juplo.de>
Date: Sat, 14 Mar 2026 15:00:57 +0000 (+0100)
Subject: Eindeutigere Benennung der erfassten Zeitstempel
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=975f9fef79d9c23ecb137cb40ea0d333b81624f6;p=demos%2Fkafka%2Ftraining

Eindeutigere Benennung der erfassten Zeitstempel
---

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 0bab4426..60424bc3 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -63,7 +63,7 @@ public class ExampleProducer
 
   void send(String key, String value)
   {
-    final long time = System.currentTimeMillis();
+    final long sendRequested = System.currentTimeMillis();
 
     final ProducerRecord<String, String> record = new ProducerRecord<>(
       topic,  // Topic
@@ -73,7 +73,7 @@ public class ExampleProducer
 
     producer.send(record, (metadata, e) ->
     {
-      long now = System.currentTimeMillis();
+      long sendRequestProcessed = System.currentTimeMillis();
       if (e == null)
       {
         // HANDLE SUCCESS
@@ -85,7 +85,7 @@ public class ExampleProducer
           metadata.partition(),
           metadata.offset(),
           metadata.timestamp(),
-          now - time
+          sendRequestProcessed - sendRequested
         );
       }
       else
@@ -96,20 +96,20 @@ public class ExampleProducer
           id,
           key,
           value,
-          now - time,
+          sendRequestProcessed - sendRequested,
           e.toString()
         );
       }
     });
 
-    long now = System.currentTimeMillis();
+    long sendRequestQueued = System.currentTimeMillis();
     produced++;
     log.trace(
       "{} - Queued message {}={}, latency={}ms",
       id,
       key,
       value,
-      now - time
+      sendRequestQueued - sendRequested
     );
   }