From: Kai Moritz <kai@juplo.de>
Date: Sun, 20 Aug 2023 08:47:54 +0000 (+0200)
Subject: WIP
X-Git-Tag: rebase--2023-08-20~14
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=c746974770de2f32149d72f89f5918600e6f390d;p=demos%2Fkafka%2Fchat

WIP
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeService.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeService.java
index a67d6299..ce1a72eb 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeService.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaChatHomeService.java
@@ -63,15 +63,6 @@ public class KafkaChatHomeService implements ChatHomeService
     return Mono.justOrEmpty(chatrooms[shard].get(id));
   }
 
-  @Override
-  public int[] getOwnedShards()
-  {
-    return IntStream
-        .range(0, chatrooms.length)
-        .filter(i -> chatrooms[i] != null)
-        .toArray();
-  }
-
   @Override
   public Flux<ChatRoom> getChatRooms(int shard)
   {