1

発注ノードが相互に接続されておらず、kafkaがメッセージを7日間だけ保持するので、新しい発注者を追加すると、元帳をダウンロードすることができます。注文ノードの同期はどのように機能しますか?

また、注文者ノードを7日間以上シャットダウンした場合、カフェのパーティションで7日間に起こったトランザクションが見つからない場合、どのように同期してローカルに更新するのですか元帳。

答えて

3

1.0では、カフカブローカーはlog.retention.ms = -1(出典:documentation、ステップ4e)で設定します。

これにより、時間ベースの保存が無効になり、セグメントの有効期限が切れなくなります。これは、次のことを意味します。

  1. パーティションは、チャネルのトランザクション履歴全体をホストします。
  2. 新たな発注者サービスノード(OSN)は、任意の時点で追加することができ、カフカブローカーを使用して、すべてのチャネルと完全に同期することができます。

1.xトラック内のマイナーリリースでは、OSNのレジャープルーニングをサポートします。つまり、ブローカは(常にコンフィギュレーションブロックから開始する)トランザクション履歴の整理されたシーケンスを維持する必要があり、新しい OSNはそのコンフィギュレーションブロックにのみ同期を戻すことができます。

関連する問題