From: Kai Moritz Date: Fri, 14 Apr 2023 09:57:11 +0000 (+0200) Subject: NEU X-Git-Tag: kafkadata~27 X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=43b2f8b3bdac4c19035fc1c39ba9e0bddaa4a4a0;p=demos%2Fkafka%2Fchat NEU --- diff --git a/README.txt b/README.txt index b6a9be42..8aaea7be 100644 --- 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.