From b093040c512c5666ce1753c61ed3689c4ddb1033 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 19 Jan 2025 10:56:05 +0100
Subject: [PATCH] =?utf8?q?Logmeldungen=20verwenden=20Methodenparameter,=20?=
 =?utf8?q?wo=20m=C3=B6glich?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/ExampleProducer.java | 15 +++++++--------
 1 file changed, 7 insertions(+), 8 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 72fa2dcb..bcd3d401 100644
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -81,8 +81,8 @@ public class ExampleProducer
         log.debug(
             "{} - Sent message {}={}, partition={}:{}, timestamp={}, latency={}ms",
             id,
-            record.key(),
-            record.value(),
+            key,
+            value,
             metadata.partition(),
             metadata.offset(),
             metadata.timestamp(),
@@ -93,11 +93,10 @@ public class ExampleProducer
       {
         // HANDLE ERROR
         log.error(
-            "{} - ERROR for message {}={}, timestamp={}, latency={}ms: {}",
+            "{} - ERROR for message {}={}, latency={}ms: {}",
             id,
-            record.key(),
-            record.value(),
-            metadata == null ? -1 : metadata.timestamp(),
+            key,
+            value,
             now - time,
             e.toString()
         );
@@ -108,8 +107,8 @@ public class ExampleProducer
     log.trace(
         "{} - Queued message {}={}, latency={}ms",
         id,
-        record.key(),
-        record.value(),
+        key,
+        value,
         now - time
     );
   }
-- 
2.20.1