Partition & Offset stehen eindeutig in der Log-Meldung

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index bcd3d4013d7bfb9176f0f6aebe3f1a44ce783113..772fc2b3c2f10cc15e09835ae3a5c9dae9ae55cc 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -79,7 +79,7 @@ public class ExampleProducer
         // HANDLE SUCCESS
         produced++;
         log.debug(
-            "{} - Sent message {}={}, partition={}:{}, timestamp={}, latency={}ms",
+            "{} - Sent message {}={}, partition={}, offset={}, timestamp={}, latency={}ms",
             id,
             key,
             value,