1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.Message;
4 import lombok.RequiredArgsConstructor;
5 import org.apache.kafka.clients.consumer.Consumer;
6 import org.apache.kafka.common.TopicPartition;
9 @RequiredArgsConstructor
12 private final Consumer consumer;
13 private final TopicPartition tp;
16 void handleMessage(Message message)