NEU
authorKai Moritz <kai@juplo.de>
Fri, 14 Apr 2023 09:57:11 +0000 (11:57 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 15 Apr 2023 08:13:44 +0000 (10:13 +0200)
README.txt

index b6a9be4..8aaea7b 100644 (file)
@@ -27,6 +27,19 @@ Aktuelle Idee für die Kafka-Anbindung
   Zugriffe eine `ShardNotOwnedException` erzeugt.
   - Dadurch wird das Zustands-Handling *extrem vereinfacht*, da Anfragen,
     die *während* einem Rebalance auflaufen
+- *Lade-Modus - Initialisierung und Abschluss-Bedingung:*
+  - Wenn durch einen Rebalance in den Lade-Modus gewechselt wird, muss die
+    *tatsächliche* Offset-Position der zuletzt geschriebenen Nachrichten
+    für die zugeordneten Partitionen ermittelt werden.
+  - Anschließend wird ein Seek auf die Offset-Position 0 (später: auf die
+    in den lokalen Daten gespeicherte Offset-Position) durchgeführt.
+  - Der Lade-Modus ist abgeschlossen, wenn für alle zugeordneten Partitionen
+    der zum Rebalance-Zeitpunkt ermittelte Offset der aktuellsten Nachrichten
+    erreicht ist.
+  - Wenn ein weiterer Rebalance erfolgt, während der Lade-Modus bereits
+    aktiv ist, sollte es genügen, die Informationen über die zugeordneten
+    Partitionen zu aktualisieren und die Aktuellen Offsets für diese neu
+    zu ermitteln.
 - *Lade-Modus vs. Default-Modus:*
   - Nur während des Lade-Modus *liest*  die `KafkaChatRoomServcie`-Instanz
     tatsächlich die Nachrichten aus den zugeordneten Partitionen.