From d0c1b4604fd1539747c6cc28e09960654c30e05b Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 8 Jul 2024 09:17:14 +0200 Subject: [PATCH] popular: 1.4.0 - Log-messages contains timestamp and readable time --- src/test/java/de/juplo/kafka/wordcount/popular/TestData.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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)); -- 2.20.1