apache-zookeeper

0熱

1答えて

ZooKeeper＆Solr Cloud - 私はSchema.xmlファイルを変更する必要があります

/home/~/Desktop/schema.xmlでZooKeeperの/configs/DMF-index-transformed/schema.xmlファイルを更新したいと思います。私はこの問題に似たリンクを持っていますsame problem and resolve。しかし、それは私の問題だったので、新しいトピックを開くという希望がありました。 sh zkcli.sh -cmd upcon

0熱

1答えて

動物園のインストールがWindowsで動作しない10

JAVA_HOMEが正しく設定されています。そして、私は今このエラーが発生しています。ここで C:\projects\zookeeper\zk\bin>call "C:\Program Files\Java\jdk-9"\bin\java "-Dzookeeper.log.dir=C:\projects\zookeeper\zk\bin\..\logs" "-Dzookeeper.root.log

1熱

2答えて

Zookeeperが実行中であるかどうかをプログラムで確認する方法

私たちのアプリケーションでZookeeperが起動しているかどうかを確認しようとしています。どうすればこの機能を実現できますか？

1熱

1答えて

Apache Curatorロックが発生してから先に発生する

私は、ロックを保持している間に、いくつかの動物園（永続的）ノードを作成/更新/削除する動物園のクライアントだとします（InterProcessMutex）。私はそれをリリースした後、同じロックを取得する別のクライアントが私の変更を参照してください保証されていますか？各動物園のサーバーでノードの更新が行われた後にロックの解除が行われるため、答えは「はい」としますが、誰でもこの前提を確認できますか？

1熱

1答えて

Zookeeper：ホスト名の解決に失敗しました

私はZookeeperをOpenShift/Kubernetes環境で実行しています。 configデータを確実に永続化するために、私はzookeeperをStatefulSetとしてセットアップしました。 zoo.cfgで3つのサーバーをホスト名で構成しましたが、起動時にホスト名の解決に失敗します。クラスタ内でnslookupを使用してホスト名が確かに解決できることを確認しました。 zoo.cf

0熱

1答えて

Microservicesマスター/スレーブパターン

ありますが、高可用性におけるmicroservicesのクラスタを実行するシナリオですが、あなたは（キューから、ポーリングデータベースを消費する）特定の操作を実行するためにそれらの一つだけをしたいと思いこのユースケースに関連するベストプラクティスは何ですか？ Zookeeperをレジストリとして使うべきか、それとも他の適切なテクノロジーが必要ですか？

2熱

2答えて

カフカキャッシュzkVersionは飼い犬仲介業者ブローカーのものと等しくない

私は3人のブローカーを持つカフカクラスターを持っています。私は最近、クラスタから外に出ているブローカと、リーダーである利用不可能なエラーを投げかけているプロデューサ/コンシューマとの問題に直面し始めました。私は次の一連のイベントを参照のログを調べるには： [2017-10-09 14:48:50,600] INFO [ReplicaFetcherManager on broker 6] Remo

0熱

1答えて

ZooKeeperクラスタごとに複数のCuratorフレームワークインスタンスを使用すると、どのような結果が得られますか？ Apacheのキュレーターのウェブサイトで

は、ノートがここにあり http://curator.apache.org/curator-framework/index.html 重要：CuratorFrameworkインスタンスは完全にスレッドセーフです。あなたのアプリケーションでは、ZooKeeperクラスタごとに1つのCuratorFrameworkを共有する必要があります。しかし、複数のインスタンスを使用することはどのように悪いです

0熱

2答えて

コンフルエントスキーマレジストリオフセット管理

コンフルエントスキーマレジストリをAvroスキーマリポジトリとして使用します。私が観察したことは、Zookeeperにコンシューマーオフセット管理がないことです。それはスキーマレジストリが設計されているためですか？ZookeeperではなくKafkaにオフセットを保存しないか、これはカフカのコンパクトログ/トピックの場合の標準的なデザインパターンですか？

1熱

1答えて

が、これは（すべてローカル）を実行しているモジュール私はPythonコード

からカフカに生成することはできませんスクリプトにsend()コールがあります。 producer = KafkaProducer(bootstrap_servers=['localhost:9092']) producer.send('test', 'entry1') 15秒ごとにカフカサーバー上のほぼすべてのsend()コール利回りこれらのエラー： [2017-10-16 18:59:1