問題タブ [apache-curator]

キュレーター フレームワークを使用して Zookeeper サーバーに接続していますが、奇妙な DNS 解決の問題が発生しています。スレッドの jstack ダンプは次のとおりです。

スレッドはネイティブ メソッドでスタックしているようで、決して戻りません。また、非常にランダムに発生するため、一貫して再現することはできませんでした。何か案は？

私はキュレーターを初めて使用します。キュレーター フレームワークがクラ​​イアント接続の再調整を内部的に処理するかどうかに興味がありますか? そうでない場合、クライアントが接続するノードをランダムに選択することはわかっていますが、クライアント接続の再調整を行う必要がありますか?

どうもありがとう

最近、ZooKeeper とその設計について学びました。ZooKeeper サービスが複数の ZooKeeper サーバーでサポートされていることは理解していますが、これらのサーバーの 1 つをグループのリーダーとして選択する必要があります。

次に、LeaderLatch と LeaderElection の Apache Curator レシピを調べ始めました。リーダーの選択についてではなく、リーダー (オーガナイザー) としてのプロセスの選択について話しています。

私はこれに困惑しています。Curator のレシピと ZooKeeper が 2 つの異なる種類のリーダーについて話している理由を説明してくれる人がいますか?

そして、彼らが実際に異なっているとすれば、これらのリーダーは互いにどのように関係しているのだろうか?

私のコードは次のようなものです：

curator-framework のバージョンは 3.1.0 です。以下にリストされているエラーが発生しました。

curator を使用treeCacheする場合、キャッシュの準備ができていることを確認するにはどうすればよいですか?

の後、すぐcache.start()に呼び出すと が返されるので、キャッシュの準備ができていることを確認するにはどうすればよいですか? 誰か例を教えてください。ありがとうgetCurrentDatanull

複数の子を持つベースパスがあります。ベースパスにウォッチャーを追加し、アプリケーションの起動時にすべての子を追加しています。

今、期限切れの Event in process メソッドをキャッチしています。

このメソッドは有効期限が切れると実行されますが、監視はノードの変更でトリガーされません。

AMQP は初めてですが、Apache Zookeeper で Curator Framework を使用して AMQP を体験したいので、Github サンプル プロジェクトへのリンクと、これを理解するのに役立つ情報があれば教えてください。

Spark は Zookeeper と統合されていますか? Apache Curator を使用せずに、Spark で Zookeeper から構成情報を読み取りたいです。私の質問は、Spark の Java API を使用してこれを取得できるかどうかです。

ありがとうございました！