2つのカフカブローカのクラスタとレプリケーションファクタ2のトピックがあります。ブローカの1つが死んでも、私のプロデューサはこの劣化クラスタに新しいメッセージを送信し続けますか? 1ノードの?あるいは、レプリケーションファクタ2は2つの生存ノードを必要とし、メッセージは拒否されますか?カフカレプリカの1つがダウンした場合
1
A
答えて
3
メッセージが無視されることはありません。生きているブローカーの数は構成されたレプリカよりも小さい。新しいカフカブローカがクラスタに参加するたびに、そのノードにデータが複製されます。
レプリケーションファクタを3以上に設定し、ブローカを1つだけ起動することで、このシナリオを再現できます。すぐに新しいノードがカフカのクラスタに参加して、データが複製されます
0
、レプリカ係数がパブリッシャメッセージに
4
には影響しません。これは、いくつかの要因に依存します。
- あなたのプロデューサーである何acksの設定? 「すべて」に設定すると、メッセージがISRリスト内のすべてのノードに複製されるまで、リーダブローカはACKで応答しません。この時点で、彼がACKを気にしているかどうかを決定するのはあなたのプロデューサーの責任です。
- min.insync.replicasの価値は?ノードの数がこの設定よりも小さい場合、ブローカーリーダーは、ノードが使用可能になるまでプロデューサからのメッセージを受け入れません。
基本的に、プロデューサは、より多くのノードがアップするまで、しばらくポーズを取る可能性があります。
0
複製因子2は、2つのライブブローカーを必要としない1つのブローカーがダウンしている間、それはメッセージをパブリッシュそれらの構成 に依存 - のACK - @Javier前述したようにmin.insync.replicas
は、これらの構成を確認してください
関連する問題
- 1. cassandraノードがダウンした場合
- 2. ネットワークがダウンした後にネットワークが復旧した場合の通知
- 3. 他のコアがダウンしている場合、Shardは1つのコアから結果を返しますか?
- 4. カサンドラ3つのノードクラスタとすぐに1つのノードがダウンし
- 5. 何らかのエラーが発生した場合、Nodejs Expressサーバーがダウンする
- 6. キュウリが1つ失敗した場合に次のテストをスキップ
- 7. アプリケーションがダウンしている場合の回避策
- 8. Django UserCreationFormパスワードが1つの場合
- 9. 特定のページが数日間ダウンした場合に返されるHTTPステータス
- 10. 1つのSPサーバーのiisがダウンしたときのSharepoint Webアプリケーション
- 11. URLがダウンした場合に電子メール通知を送信するプログラム
- 12. カラムの1つが変更された場合のPostgreSQLトリガ
- 13. タスクの1つが失敗した場合、セロリチェーンが破損します
- 14. 1つのクエリが失敗した場合、次のsqlクエリにジャンプします
- 15. 証明書が無効/取り消された場合、IOSアプリケーションがダウンする
- 16. 1つのテーブルでSELECTを選択した場合
- 17. SQLのユーザーロールが1つの場合のみ選択します
- 18. 1つの表にNULL値がある場合のデータ結合
- 19. が他の場合組み合わせると1つの文
- 20. ノードの1つがダウンしているときにCassandraが動作しない
- 21. 1つのオブジェクトがすべてのオブジェクトのロールバックに失敗した場合
- 22. レコードが1つしかない場合のREST APIエンドポイント
- 23. 最初の1つが失敗した場合は別のステップにスキップ
- 24. 2ループの場合1つの結果
- 25. ウェブサイトのウィジェットがダウンしている場合に別のスクリプトを読み込む
- 26. (a = 1)が真の場合
- 27. pingがダウンしている場合に限り、Bashが続行されます。
- 28. シェルスクリプトを使用して、tomcatがアップまたはダウンしているかどうかをチェックし、ダウンした場合は再起動します。
- 29. 1つのタスクを2つのコミットに分割した場合のコミットメッセージ
- 30. UDPサーバがダウンしている場合はどうなるのですか?