From f675d0a342b9d5ae75d98a165d43434364704c18 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 6 Jul 2024 09:21:45 +0200 Subject: [PATCH] Refined log messages --- .../counter/StreamStreamJoinTopologyTest.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) 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 --- 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 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 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()); } -- 2.20.1