From 43b2f8b3bdac4c19035fc1c39ba9e0bddaa4a4a0 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 14 Apr 2023 11:57:11 +0200 Subject: [PATCH 1/1] NEU --- README.txt | 13 +++++++++++++ 1 file changed, 13 insertions(+) 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. -- 2.20.1