From 66b83a7034771b987dae9f20ba83828a3b6c307c Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 13 Jul 2024 11:36:27 +0200
Subject: [PATCH] Refined log-messages for better redability

---
 .../de/juplo/kafka/wordcount/counter/JoinTopologyTest.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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()))
-- 
2.20.1