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 0bab4426241a7490ea386759ecdb68a63327fa67..60424bc319ab2bbf0ba78b71a44e4fd5b4f0db54 100644 (file)
--- 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
     );
   }