Wenn zwei Kafka-Streams von demselben Kafka-Thema konsumiert werden, wird im Fall der Fehlertoleranz, wenn ein Kafka-Stream ausgefallen ist, Kafka State Store im zweiten Kafka-Stream repliziert. wenn zuerst zurück kommt, was mit dem Staatsspeicher des zweiten Kafka-Stroms geschehen wird.Kafka State Store
Wenn die fehlerhafte Instanz zurückkommt, wird eine weitere Neuverteilung ausgelöst, und einige Aufgaben werden auf diese wiederherstellende Instanz migriert. Es ist schwierig vorherzusagen, welche Aufgabe migriert wird - es kann passieren, dass der Laden zurück migriert wird. Es gibt jedoch viele Laufzeitabhängigkeiten, die sich darauf auswirken, welche Aufgaben migriert werden. In jedem Fall ist der "alte Speicher" höchstwahrscheinlich nach dem Fehler beschädigt und Streams werden ihn am wahrscheinlichsten löschen (und von Grund auf neu erstellen, wenn er zurückmigriert wird).