+package de.juplo.kafka.chat.backend.persistence.kafka;
+
+import de.juplo.kafka.chat.backend.domain.Message;
+import lombok.RequiredArgsConstructor;
+import org.apache.kafka.common.TopicPartition;
+
+
+@RequiredArgsConstructor
+class ChatRoomActiveMessageHandlingStrategy implements MessageHandlingStrategy
+{
+ private final TopicPartition tp;
+
+ @Override
+ public MessageHandlingStrategy handleMessage(Message message)
+ {
+ chatrooms[tp.partition()].put()
+ return this;
+ }
+}