FIX

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 e42ea9f..de68194 100644 (file)
--- 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
@@ -299,16 +299,15 @@ public class DataChannel implements Runnable, ConsumerRebalanceListener
     return infoChannel
         .getChatRoomInfo(id)
         .map(chatRoomInfo ->
-        {
-          if (chatRoomInfo == null) return null;
-          return chatRoomData[shard].computeIfAbsent(
-              id,
-              (chatRoomId) ->
-              {
-                log.info("Creating ChatRoom {} with buffer-size {}", chatRoomId, bufferSize);
-                KafkaChatMessageService service = new KafkaChatMessageService(this, chatRoomId);
-                return new ChatRoomData(clock, service, bufferSize);
-              });
-        });
+          chatRoomInfo == null
+              ? null
+              : chatRoomData[shard].computeIfAbsent(
+                  id,
+                  (chatRoomId) ->
+                  {
+                    log.info("Creating ChatRoom {} with buffer-size {}", chatRoomId, bufferSize);
+                    KafkaChatMessageService service = new KafkaChatMessageService(this, chatRoomId);
+                    return new ChatRoomData(clock, service, bufferSize);
+                  }));
   }
 }