1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import lombok.RequiredArgsConstructor;
4 import lombok.extern.slf4j.Slf4j;
5 import org.apache.kafka.clients.consumer.Consumer;
8 @RequiredArgsConstructor
10 public class ChatHomeConsumer extends Runnable
12 private final Consumer<String, MessageTo> consumer;