+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 ChatroomInactiveMessageHandlingStrategy implements MessageHandlingStrategy
+{
+ private final TopicPartition tp;
+
+ @Override
+ public MessageHandlingStrategy handleMessage(Message message)
+ {
+ KafkaChatHomeService.log.warn("Not handling message {} for partition {}", message, tp);
+ return this;
+ }
+}