From: Kai Moritz <kai@juplo.de>
Date: Sun, 24 Sep 2023 19:38:46 +0000 (+0200)
Subject: refactor: Added logging of loaded messages
X-Git-Tag: rebase--2024-02-03--15-10~6
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=681d57ac2d1a3dd44a3753dc34d2d0b9e3e55aee;p=demos%2Fkafka%2Fchat

refactor: Added logging of loaded messages
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
index 2fa4998e..7fdaf049 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
@@ -266,6 +266,11 @@ public class DataChannel implements Runnable, ConsumerRebalanceListener
     KafkaChatMessageService kafkaChatRoomService =
         (KafkaChatMessageService) chatRoomData.getChatRoomService();
 
+    log.debug(
+        "Loaded message from partition={} at offset={}: {}",
+        partition,
+        offset,
+        message);
     kafkaChatRoomService.persistMessage(message);
   }