From: Kai Moritz Date: Mon, 8 Jul 2024 07:17:14 +0000 (+0200) Subject: popular: 1.4.0 - Log-messages contains timestamp and readable time X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fpopular--sliding-window;p=demos%2Fkafka%2Fwordcount popular: 1.4.0 - Log-messages contains timestamp and readable time --- diff --git a/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java b/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java index e26d532..8f8982f 100644 --- a/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java +++ b/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java @@ -152,8 +152,9 @@ class TestData getInputMessages().forEach(message -> { log.info( - "Sending@{}: {} -> {}", + "Sending@{} ({}): {} -> {}", message.time.toEpochMilli(), + message.time, message.key, message.value); consumer.accept(message.time, new KeyValue<>(message.key, message.value));