package de.juplo.kafka.chat.backend.persistence.kafka;
+import de.juplo.kafka.chat.backend.domain.Message;
+import lombok.RequiredArgsConstructor;
+import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.common.TopicPartition;
+
+
+@RequiredArgsConstructor
class MessageHandler
{
+ private final Consumer consumer;
+ private final TopicPartition tp;
+
+
+ void handleMessage(Message message)
+ {
+ }
}