1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.Message;
4 import lombok.AllArgsConstructor;
6 import lombok.NoArgsConstructor;
8 import java.time.LocalDateTime;
14 public class MessageTo
20 public Message toMessage(long offset, LocalDateTime timestamp)
22 return new Message(Message.MessageKey.of(user, id), offset, timestamp, text);
25 public static MessageTo from(Message message)
30 message.getUsername(),
31 message.getMessageText());