From bebb8cd0c97e5a3eba8389a158d206da307e66df Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 8 Jul 2024 09:08:44 +0200 Subject: [PATCH] popular: 1.4.0 - Log-message for sending logs epoch-timestamp --- .../java/de/juplo/kafka/wordcount/popular/TestData.java | 6 +++++- 1 file changed, 5 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 b4b8e4f..e26d532 100644 --- a/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java +++ b/src/test/java/de/juplo/kafka/wordcount/popular/TestData.java @@ -151,7 +151,11 @@ class TestData { getInputMessages().forEach(message -> { - log.info("Sending@{}: {} -> {}", message.time, message.key, message.value); + log.info( + "Sending@{}: {} -> {}", + message.time.toEpochMilli(), + message.key, + message.value); consumer.accept(message.time, new KeyValue<>(message.key, message.value)); }); } -- 2.20.1