--- /dev/null
+package de.juplo.kafka.chat.backend.persistence.kafka;
+
+import de.juplo.kafka.chat.backend.domain.ChatRoom;
+import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
+import reactor.core.publisher.Mono;
+
+import java.util.UUID;
+
+
+public class KafkaChatRoomFactory implements ChatRoomFactory
+{
+ @Override
+ public Mono<ChatRoom> createChatRoom(UUID id, String name)
+ {
+ return null;
+ }
+}