refactor: Added logging of loaded messages
authorKai Moritz <kai@juplo.de>
Sun, 24 Sep 2023 19:38:46 +0000 (21:38 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 27 Jan 2024 14:19:30 +0000 (15:19 +0100)
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java

index 532a3c1..c290846 100644 (file)
@@ -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);
   }