2017-06-16 9 views
0

私はプロジェクトを運営しています。私の目標は、カフカクラスターを設計することです。ある機械が死んだときに、そのカフカのデータがすべて消えてしまうのを防ぐ。私はKafkaの複製をバックアップするために別のマシンに設定できるのだろうか?カフカの複製を別のマシンに展開できますか?

答えて

4

レプリカコピーが最終的に作成されるように、トピックにレプリケーションファクタを2または3に設定することに加えて、acks = allを使用してメッセージを発行して、確認応答がデータが書き込まれたすべてのレプリカさもなければ、acks = 1では、1つのコピーがコミットされた後にackが得られ、acks = 0では、acksはまったく得られないので、公開されたメッセージがKafkaコミットログに記録されたかどうかは決して分かりません。

また、インシンクレプリカのみがリーダーになることができるように、不正なリーダー選択パラメータをfalseに設定します。

0

はい、レプリケーションファクタはこれを定義します。

1

カフカでは、トピックのレプリケーションファクタを定義することができ、この方法では各ブローカがより多くのブローカにレプリケートされます。その1つは、プロデューサとコンシューマがメッセージを交換するために接続するリーダーです。もう1人はリーダーからのメッセージのコピーを同期させるフォロワーになります。リーダーが倒れた場合、新しいリーダー選挙がすべてのシンク・レプリカの間で開始されます。 Kafkaは、NがレプリケーションファクタであるN-1の失敗したブローカをサポートします。

関連する問題