apache-zookeeper

2熱

1答えて

からZooKeeper Cluster Set-Up Documentを読んでいました。しかし残念ながら、ZooKeeperサービスを起動するjavaコマンドを理解できません。私の知る限り-cpが-classpathオプションを意味し、（私はwrong.thanksた場合は修正してください）を知っていたとして $ java -cp zookeeper.jar:lib/log4j-1.2.15.j

1熱

1答えて

ブローカーが削除された後にKafkaパーティションリーダーが更新されない

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

1熱

1答えて

カフカ3ノードクラスタの飼い葉桶が接続に失敗する

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

0熱

1答えて

Docker zookeeperは作成したカフカのトピックについて忘れました

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

1熱

1答えて

JDBC経由でZookeeper Service Discoveryモードでハイブを接続できません

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

2熱

2答えて

飼い葉桶のsasl認証の問題

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

2熱

1答えて

kubernetes上のKafkaマルチブローカーのセットアップのために宣伝されたリスナーを指定する方法と、そのクラスターを経験的に公開する方法はありますか？

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

0熱

1答えて

カフカと飼育係TLS

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

1熱

1答えて

Zookeper +キュレーター：私はキュレーター2.12.0で飼育係を使用している時計

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

0熱

1答えて

飼い葉桶のログのフォーマットは？

私は動物園のログフォーマットを理解しようとしています。そのために正規表現を書くことができますが、ログに正確に表示されるものは何も見つかりませんでした。以下は動物園のログラインです。誰かが正確に[]の間に記録されているものを教えてくれますか？パッケージ名/クラス名ですか？ 0.0.0.0とは何ですか？ 2017年8月8日08：13：25635 - INFO [NIOServerCxn.Factor