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