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

index a7c7f84..b6a9be4 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 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