Refined log messages

diff --git a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
index 39f59b7..f34dfbe 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
+++ b/src/test/java/de/juplo/kafka/wordcount/counter/StreamStreamJoinTopologyTest.java
@@ -103,9 +103,9 @@ public class StreamStreamJoinTopologyTest
   {
     TestRecord<String, String> record = new TestRecord<>("foo", value, T.plusSeconds(second));
     log.info(
-        "Sending left: {} at time {}",
-        record.value(),
-        LocalTime.ofInstant(record.getRecordTime(), ZoneId.systemDefault()));
+        "Sending   LEFT  at {}: {}",
+        LocalTime.ofInstant(record.getRecordTime(), ZoneId.systemDefault()),
+        record.value());
     inLeft.pipeInput(record);
   }
 
@@ -113,9 +113,9 @@ public class StreamStreamJoinTopologyTest
   {
     TestRecord<String, String> record = new TestRecord<>("foo", value, T.plusSeconds(second));
     log.info(
-        "Sending right: {} at time {}",
-        record.value(),
-        LocalTime.ofInstant(record.getRecordTime(), ZoneId.systemDefault()));
+        "Sending   RIGHT at {}: {}",
+        LocalTime.ofInstant(record.getRecordTime(), ZoneId.systemDefault()),
+        record.value());
     inRight.pipeInput(record);
   }
 
@@ -135,9 +135,9 @@ public class StreamStreamJoinTopologyTest
         .readRecordsToList()
         .stream()
         .peek(record -> log.info(
-            "Received join-outcome: {} for time {}",
-            record.value(),
-            LocalTime.ofInstant(record.getRecordTime(), ZoneId.systemDefault())))
+            "Receiving join for {}: {}",
+            LocalTime.ofInstant(record.getRecordTime(), ZoneId.systemDefault()),
+            record.value()))
         .map(record -> record.value());
   }