NEU

[demos/kafka/chat] / README.txt

diff --git a/README.txt b/README.txt
index b6a9be4..8aaea7b 100644 (file)
--- a/README.txt
+++ b/README.txt
@@ -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.