1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.ChatRoom;
4 import de.juplo.kafka.chat.backend.domain.ChatRoomFactory;
5 import reactor.core.publisher.Mono;
10 public class KafkaChatRoomFactory implements ChatRoomFactory
13 public Mono<ChatRoom> createChatRoom(UUID id, String name)