1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import lombok.RequiredArgsConstructor;
4 import lombok.extern.slf4j.Slf4j;
6 import java.util.function.Consumer;
9 @RequiredArgsConstructor
11 public class ChatHomeConsumer extends Run
13 private final Consumer<String, MessageTo> consumer;