From: Kai Moritz <kai@juplo.de>
Date: Sat, 13 Jul 2024 09:36:27 +0000 (+0200)
Subject: Refined log-messages for better redability
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=66b83a7034771b987dae9f20ba83828a3b6c307c;p=demos%2Fkafka%2Fwordcount

Refined log-messages for better redability
---

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/JoinTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/JoinTopologyTest.java
index 1b0b74b..5323663 100644
--- a/src/test/java/de/juplo/kafka/wordcount/counter/JoinTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/JoinTopologyTest.java
@@ -116,7 +116,7 @@ public class JoinTopologyTest
   {
     TestRecord<String, String> record = new TestRecord<>(KEY, value, Instant.ofEpochSecond(second));
     log.info(
-        "Sending  LEFT  @ {}: {}={}",
+        "Sending  LEFT  @ {}: {} = {}",
         record.getRecordTime().toEpochMilli(),
         record.key(),
         record.value());
@@ -127,7 +127,7 @@ public class JoinTopologyTest
   {
     TestRecord<String, String> record = new TestRecord<>(KEY, value, Instant.ofEpochSecond(second));
     log.info(
-        "Sending  RIGHT @ {}: {}={}",
+        "Sending  RIGHT @ {}: {} = {}",
         record.getRecordTime().toEpochMilli(),
         record.key(),
         record.value());
@@ -145,7 +145,7 @@ public class JoinTopologyTest
         .readRecordsToList()
         .stream()
         .peek(record -> log.info(
-            "Received join  @ {}: {}={}",
+            "Received join  @ {}: {} = {}",
             record.getRecordTime().toEpochMilli(),
             record.key(),
             record.value()))