apache-zookeeper

    1

    1答えて

    私は3人のブローカーバージョン0.10.2.1を持つマラソン/メソスによって管理されるカフカクラスターを持っています。ドッカー画像はwurstmeister/kafka-dockerに基づいています。起動時に自動的に順番に割り当てられるbroker.id=-1とリーダーは、自動再平衡auto.leader.rebalance.enable=trueです。クライアントはバージョン0.8.2.1です。

    1

    1答えて

    私は3ノードカフカクラスター設定に苦労しています。私はすべてのSOの答えを見て、すべてを正しくしているようです。しかし、Zookeeperは同期に失敗し、カフカサーバーは接続しません。 は、ここに私の飼育係の設定SOの答えの一つで提案されているように、私は0.0.0.0にserver.idを設定している他のサーバーのそれぞれに dataDir=/home/kafka/zookeeper/data

    0

    1答えて

    zookeeperが作成したトピックについて忘れてしまった問題を、私は動物園のコンテナとカフカのコンテナを止めて再開することができます。問題は、ドッカーを作成するときに発生します。 再起動後、kafkaが/ dataディレクトリのトピックで正しく再オープンされますが、describe topic関数を呼び出した後に空のリストが存在するかのように表示されます。 私は間違っていますか? unset J

    1

    1答えて

    javax.sql.DataSourceを使用してハイブに接続し、Zookeeperサービスディスカバリ(Ambariから取得)文字列をHiveに渡すjdbc接続を作成しています。 Zookeeper Hive URL : jdbc:hive2://localhost:2181/;serviceDiscoveryMode=zooKeeper;zooKeeperNamespace=hiveserve

    2

    2答えて

    私はKafkaのために私の動物園の飼育係のためにSASL認証を設定しようとしています。私は以下 https://cwiki.apache.org/confluence/display/ZOOKEEPER/Client-Server+mutual+authentication は私server_jaas.confファイルが 以下 Server { org.apache.kafka.comm

    2

    1答えて

    Azureでホストされているkubernetesクラスタにマルチブローカーkafkaを設定しようとしています。私は1つのブローカセットアップが動作しています。マルチブローカーの設定では、カフカサービスを管理する飼育係ノード(3)のアンサンブルがあります。私はkafkaクラスターを複製係数3の複製コントローラーとして展開しています。それは3つのブローカーです。 3つのブローカーをZookeeperに

    0

    1答えて

    私はカフカブローカーの交換のためのTLSを有効にしようと飼育係TLSに関する考えを持っていたのです。現在、Apache Kafkaのドキュメンテーションでは、ZK TLSのセットアップ(おそらくそれが別のApacheプロジェクトだからです)やパフォーマンスの影響についてはあまり言及されていません。 質問は、私はブローカー・クライアントとインターブローカー交換確保を持つことができない、でしょうか?

    1

    1答えて

    を削除/ノード削除を監視します。 私は正常に再びウォッチャーとGetChildrenメソッドを呼び出すようにタスクを提出するウォッチャーで(私は事前にフルノードパスを知らない)GetChildrenメソッドを呼び出すことによって、新しいノード上で見ています。 ノードの削除を監視して削除するだけです。私はウォッチャーでcheckExistsを呼び出します。しかし、何らかの理由でノードが存在しない場合