飼育係用に 1 台、ブローカー用に 2 台の 3 台のマシンで構成される kafka クラスターを実装します。私は約 6 台のコンシューマー マシンと約 100 台のプロデューサーを持っています。
ブローカーの 1 つが失敗した場合でも、レプリケーション機能のおかげでデータ損失が回避されます。しかし、zookeeper に障害が発生し、同じマシンを起動できない場合はどうなるでしょうか。いくつか質問があります:
- Zookeeper に障害が発生した後でも、プロデューサーは指定されたブローカーにメッセージをプッシュし続けていることに気付きました。しかし、消費者はそれらを取得できなくなりました。消費者が登録解除されたためです。この場合、データは永久に失われますか?
- 実行時にブローカー構成で Zookeeper の IP を変更するにはどうすればよいですか? Zookeeper の IP を変更するには、シャットダウンする必要がありますか?
- 新しい ZooKeeper マシンが何らかの方法で以前のクラスターに持ち込まれたとしても、以前のデータは失われますか?