From: Kai Moritz <kai@juplo.de>
Date: Mon, 26 Dec 2022 12:48:05 +0000 (+0100)
Subject: feat: Added logging for the `listen`-endpoint
X-Git-Tag: TEST~72
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=47a43169cf751fe4c5fba0e9b889ffa06d4c7723;p=demos%2Fkafka%2Fchat

feat: Added logging for the `listen`-endpoint
---

diff --git a/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java b/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java
index effeccbc..da65a439 100644
--- a/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java
+++ b/src/main/java/de/juplo/kafka/chatroom/api/ChatroomController.java
@@ -71,6 +71,7 @@ public class ChatroomController
     return chatrooms
         .get(chatroomId)
         .listen()
+        .log()
         .map(message -> MessageTo.from(message));
   }
 }