カフカハイレベルプロデューサーがリーダーを選ぶ時期と頻度は? 各メッセージを送信する前に、または接続の作成時に1回だけ行うのですか?カフカリーダー選挙はいつ行われますか?
4
A
答えて
2
各ブローカーには、新しいリーダーが選出されるたびに、またはパーティション数が変更されたときに動物園キーパーによって最新の状態に保たれるトピック(およびパーティション)とそのリーダーのリストに関する情報があります。
したがって、プロデューサがブローカの1つに電話をかけると、この情報リストで応答します。プロデューサがこの情報を受け取ると、プロデューサはこれをキャッシュし、それを使用してリーダーに接続します。次回は、その特定のトピック(およびパーティション)にメッセージを送信したいときに、このキャッシュされた情報を使用します。
リーダーが1人しかいないと仮定し、そのトピック/パーティションのデュオのレプリカがなく、潰れてしまったとします。この場合、リーダーに接続しようとすると失敗します。このトピックのリーダーがあるかどうかを確認するためにキャッシュされている他のブローカーリストからリーダーをフェッチしようとします。何も見つからないので、それは同じリーダー(それは死んでいる)にヒットしようとし、再試行の最大数に達した後、それは例外をスローするでしょう!
関連する問題
- 1. IntelliJのScalaインクリメンタルコンパイルはいつ行われますか?
- 2. SQLAlchemy Coreでのコミットはいつ行われますか?
- 3. グローバル変数の初期化はいつ行われますか?
- 4. WHEREフィルタリングはいつ行われますか?
- 5. スプリント計画はいつ行われますか?
- 6. php.iniの変更はいつphp-coreで行われますか?
- 7. Angular2:プロパティバインドはいつ行われますか?
- 8. 再レンダリングはいつvueで正確に行われますか?
- 9. Angular-CLIでは、ハンドルバーはいつ実行され、HTMLテンプレート補間はいつ行われますか?
- 10. コードでオプションを選択します。選択は動的に行われます
- 11. いつASP.NET認証が行われますか?
- 12. トランザクション処理:いつロールバックが行われますか?
- 13. いつHTTPSハンドシェイクが行われますか?
- 14. 一般的なインスタンス化はいつ行われますか(つまり、単語の意味は何ですか)?
- 15. いつTask.WhenAllが列挙されますか?
- 16. Javaでは、列挙定数のコンストラクタはいつ呼び出されますか?
- 17. タスクデータローカリティNO_PREF。それはいつ使われますか?
- 18. ItemContainerGenerator.Status列挙はいつGeneratorStatus.Errorを返しますか?
- 19. バージョン管理:テーマ更新はいつ行われますか?メジャーまたはマイナーチェンジになりますか?
- 20. Stringbuilder replace() - いくつの置換が行われたかを数えますか?
- 21. JComboBoxは選択を行いますか?
- 22. スウィングでリスト選択が行われていない
- 23. Unity InjectionConstructorはいついつ実行されますか?
- 24. devDependenciesでNPMパッケージをデプロイすると、いつビルドが行われますか?
- 25. このビューは正しく行われていますか?
- 26. マッピングはDozerで順番に行われていますか?
- 27. Eclipseコードでローカリゼーションはどこで行われていますか?
- 28. システムコールset_tid_addressはいつ使われますか?
- 29. HTTPリクエストはいつ失われますか?
- 30. jquery ui autocomplete:選択が行われるまで選択リストを開いたままにする方法
プロデューサーはリーダーを選ぶわけではありません。リーダーのコンセプトはありません。あなたは何を意味しているのですか?ブローカーと消費者にはリーダー概念があります。 –
プロデューサはクラスタ内のブローカに公開する必要があります。それで、どのようにカフカのどのインスタンスをデータをプッシュするかをプロデューサが決定しますか? –
日付を書き込むトピックとパーティションによって異なります。各トピックパーティションには、そのリーダーであるブローカーが1つあります。書き込みはリーダーにのみ行われます。したがって、作成するすべてのパーティションが異なるブローカでホストされている場合、プロデューサはクラスタ内のすべてのブローカに書き込む可能性があります。 –