X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=README.txt;h=8aaea7beb2760c4310e47a1e3faeb4d17ae87ab2;hb=e7150b6822c45c520db73a96785dc0a8a81f503b;hp=a7c7f849e2c0855fcf91ba821990fd72cda26614;hpb=8d2d6ec211a5254aed17b9393948108a7a12b4b6;p=demos%2Fkafka%2Fchat

diff --git a/README.txt b/README.txt
index a7c7f849..8aaea7be 100644
--- a/README.txt
+++ b/README.txt
@@ -27,6 +27,32 @@ 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.
+  - Im Default-Modus *schreibt* sie die Nachrichten nur in die Partitionen
+    und speichert sie lokal ab, sobald die *Bestätigung durch den `Producer`*
+    erfolgt.
+  - D.h. insbesondere, dass der `KafkaConsumer` im Default-Modus für alle
+    zugeordneten Partitionen *pausiert* wird!
+  - Damit die Offset-Positon nicht unnötig zurückfällt, sollte ggf.
+    regelmäßig für alle zugeordneten Partitionen ein Seek auf die zuletzt
+    vom Producer bestätigt geschriebenen Offsets durchgeführt werden.
+  - *Beachte:_ Dies ist nicht nötig, wenn die Offsets eh in den lokal
+    gespeicherten Daten gehalten und aus diesen wiederhergestellt werden!
 - *Umsetzungs-Details:*
   - Da die in dem Interface `ConsumerRebalanceListener` definierten Methoden
     in einem zeitkritischem Setting laufen, muss das eigentliche Laden der