juplo.de Git - demos/kafka/chat/blob - src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatRoomActiveMessageHandlingStrategy.java

   1 package de.juplo.kafka.chat.backend.persistence.kafka;
   2
   3 import de.juplo.kafka.chat.backend.domain.Message;
   4 import lombok.RequiredArgsConstructor;
   5 import org.apache.kafka.common.TopicPartition;
   6
   7
   8 @RequiredArgsConstructor
   9 class ChatRoomActiveMessageHandlingStrategy implements MessageHandlingStrategy
  10 {
  11   private final TopicPartition tp;
  12
  13   @Override
  14   public MessageHandlingStrategy handleMessage(Message message)
  15   {
  16     chatrooms[tp.partition()].put()
  17     return this;
  18   }
  19 }