apache-zookeeper

-2熱

1答えて

私はとてもシンプルな（しかし完全に機能する）Apache Zookeeperのようなサービスを使いたいと思っていますか？どこから始めますか？

1熱

1答えて

CuratorTransaction KeeperErrorCode = NoNode

JavaのApache Curatorライブラリでトランザクションを使用してZooKeeperにデータを書き込もうとしています。ここでは私のコードです： private CuratorFramework client; ... private void writeToZK() { String nodePath = "/path/to/node"; client.inTr

2熱

1答えて

飼い葉桶通信プロトコル

私のカフカ消費者と飼い主の間で交換されるデータをtcpdumpを使ってデバッグする必要があります。私は飼育係のドキュメントを見に行きましたが、動物園の通信プロトコルについて書かれていません。つまり、ヘッダーを削除した後、wiresharkを使用して次のデータダンプを取得します。データ部分をどのように解釈すればよいですか？ Frame 1: 78 bytes on wire (624 bits),

3熱

1答えて

シードデータを挿入してApache ZooKeeperをどのようにしてドッキングできますか？

Dockerを使ってApache Zookeeperを実行し、シードデータを挿入したい（設定をテストするため）。私は以下のように起動スクリプトを使用してみました： Dockerfile FROM zookeeper:latest ADD startup.sh . EXPOSE 2181 CMD ["./startup.sh"] startup.sh #!/bin/sh ./bin/

2熱

1答えて

Hive Metastoreサーバーとハイブシェルを保存できません

hive-site.xmlに必要なすべてのプロパティを更新しましたが、このエラーがどこから発生しているのかわかりません。メタストアをハイブシェルに接続してハイブを開始するにはどうすればよいですか？メタストアのプロパティを更新する前に、hiveシェルが適切に動作しています。誰でもこのエラーを解決できますか？ [のHadoopの@ hduser confに] $ハイブ--serviceメタストア開

0熱

1答えて

プログラムでZooKeeperアンサンブルに接続

私はスタンドアロンサーバではなく、ZooKeeperアンサンブルにどのように接続するのか分かりません。私が見ていることから、APIは単一の接続文字列を期待しています - 個々のサーバーに！しかし、この特定のサーバーがダウンしていて、アンサンブル全体がまだ稼働している場合はどうなりますか？私はすべてのノードを事前に知っていて、それを順番に試すべきですか？私はC++と.NETアプリケーションの両方か

-1熱

1答えて

どのようにZookeeprが競合条件をハンドリングできますか？詳細を説明してください

これは飼い猫さんからのものです：調整サービスは悪くもないことが知られています。競合状態やデッドロックなどのエラーが発生しやすくなります。 ZooKeeperの背後にある動機は、分散アプリケーションの調整サービスを最初からやり直す責任を軽減することです。動物園で開発されたアプリケーションで同時に2人のユーザーがロックを取得しようとしたとき、レースコンディションが動物園でどのように機能するかを誰で

3熱

1答えて

HBaseにJava 8とZookeeperに関する問題があります

hbase 1.2.4をインストールします。 bin/start-hbase.shを実行しようとすると、次の警告が表示されます。 OpenJDK 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0 OpenJDK 64-Bit Server VM warning: ignoring

0熱

1答えて

カフカクラスター - プロデューサー

カフカについていくつか質問があります。もし誰かが私に助けてくれたら、私はとても感謝しています。は、事前にありがとう:) Q1を）私はパーティションはカフカブローカー間で分割されていることを知っています。しかし、分割は何に基づいていますか？たとえば、3つのブローカと6つのパーティションがある場合、各ブローカに2つのパーティションがあることを確認する方法はありますか？この分割は現在カフカでどのように

0熱

1答えて

行く-ZooKeeperの接続は、私が飼育係に関する質問があり、有効な接続

せずに返し、私は私が行く-飼育係を使用しています、外出先での飼育係を持つ単純なサービス探索を実装しようとしています：私は接続するたびhttps://github.com/samuel/go-zookeeper 私の質問は例えば、 zoo_keeper, _, err := zk.Connect(s, time.Second) すぐに機能が返され、エラーは報告されませんが、実際に有効な接続はまだ