Kafka State Store

Question

同じカフカトピックから2つのカフカストリームを使用している場合、フォールトトレランスのケースでは、1つのカフカストリームがダウンした場合、カフカの状態ストアは2番目のカフカストリームに複製されます。最初に2番目のカフカストリームの州の店に何が起こるか戻ってきたら。

Answer 1

障害の発生したインスタンスが戻ってきた場合、別の再調整がトリガーされ、いくつかのタスクがこの回復中のインスタンスに移行されます。どのタスクが移行されるのかを予測するのは難しいです。それは起こることがあり、そのストアは元に戻されます。しかし、どのタスクが移行されるかに影響を与えるランタイム依存性は数多くあります。いずれにしても、「古いストア」は障害の後で破損している可能性が最も高く、Streamsは最も可能性の高いものを一掃します（元に戻すと最初から再作成します）。