1 package de.juplo.kafka.chat.backend.persistence.kafka;
3 import de.juplo.kafka.chat.backend.domain.ChatHomeWithShardsTestBase;
4 import org.springframework.boot.test.context.TestConfiguration;
5 import org.springframework.context.annotation.Bean;
8 public class KafkaChatHomeTest extends ChatHomeWithShardsTestBase
11 static class Configuration
14 KafkaChatHome chatHome(ChatRoomChannel chatRoomChannel)
16 return new KafkaChatHome(numShards(), chatRoomChannel);