popular: 1.4.0 - Log-message for sending logs epoch-timestamp
authorKai Moritz <kai@juplo.de>
Mon, 8 Jul 2024 07:08:44 +0000 (09:08 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 8 Jul 2024 07:12:26 +0000 (09:12 +0200)
src/test/java/de/juplo/kafka/wordcount/popular/TestData.java

index b4b8e4f..e26d532 100644 (file)
@@ -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));
                });
        }