WIP:KafkaChatHomeTest

diff --git a/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java b/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java
new file mode 100644 (file)
index 0000000..ab24082
--- /dev/null
+++ b/src/test/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeTest.java
@@ -0,0 +1,25 @@
+package de.juplo.kafka.chat.backend.persistence.kafka;
+
+import de.juplo.kafka.chat.backend.domain.ChatHomeWithShardsTestBase;
+import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.context.annotation.Bean;
+
+
+public class KafkaChatHomeTest extends ChatHomeWithShardsTestBase
+{
+  @TestConfiguration
+  static class Configuration
+  {
+    @Bean
+    KafkaChatHome chatHome(ChatRoomChannel chatRoomChannel)
+    {
+      return new KafkaChatHome(numShards(), chatRoomChannel);
+    }
+
+    Integer numShards()
+    {
+      return 10;
+    }
+
+  }
+}