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 1b0b74b16d49a98a4eb27a80eb6d7be4a13974e4..5323663764397f8ac9242bf5a2b48651ae87bd92 100644 (file)
--- 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()))