apache-zookeeper

2熱

1答えて

__consumer_offsetsのキリングノードは、消費者にメッセージ消費をもたらしません

複製ファクタ2を持つ3つのノード（nodes0、node1、node2）Kafkaクラスタ（broker0、broker1、broker2）と、Zookeeper（Kooka tarでパッケージ化された別のノード（ノード4）。私はzookeperを開始して残りのノードの後にブローカ0を起動しました。それは__consumer_offsetsを読んでいるブローカー0ログで見られ、それらは、ブロ

0熱

1答えて

飼育係メゾス設定の問題

私はの後に、メゾス3ノードマスターと3ノードスレーブクラスターを設定しています。私はマスターの飼育係を起動したときしかし、私はエラーログに、次の取得 2017-07-05 09:46:18,568 - INFO [main:[email protected]] - Reading snapshot /var/lib/zookeeper/version-2/snapshot.100000016 2

0熱

2答えて

bashスクリプトでkafkaブローカーID（zookeeper-shell.shの結果）を変数に保存

ブローカーIDが既に使用されているかどうかを確認したいが、スクリプト内でこれを実行したい。 ./bin/zookeeper-shell.sh localhost:2181 <<< "ls /brokers/ids" 結果が得られますが、これを後で使用するために変数に保存するにはどうすればよいですか？私が興味を持っているのは、 "ls .."の実際の結果です。私は変数に結果を保存する場合 Con

0熱

1答えて

Solr：solrcloud 5.5.1から6.6.0へのアップグレード方法

このプロセスを実行するために、CentOS.ISの最新バージョンにsolrcloudをアップグレードしたいと思います。私は私のインデックスを失うことも望んでいません。

0熱

2答えて

KafkaクライアントでSASL認証を使用できますが、ZookeeperにはSASL認証は必要ありませんか？

私はこれに従いました：http://docs.confluent.io/current/kafka/sasl.html#sasl-configuration-for-kafka-brokers 私のKafkaクラスターにSASL認証を設定するには。私はすべてのクライアントがSASLを通じてブローカに認証されるようにしたいと思います。私はkafka < - >飼い猫を気にしない。なぜなら、私はカフカ

0熱

1答えて

"重大な回復不能なエラー"で終了する飼い猫のサービスを開始できません

私は飼い猫のサービスを開始できません。スタックトレースをご覧ください。トレース1： org.apache.zookeeper.server.ZooKeeperServer： Severe unrecoverable error, exiting java.io.FileNotFoundException: /var/lib/zookeeper/version-2/snapshot.40003a

1熱

1答えて

Couchbase-Kafka-ZookeeperログのConnectorエラー

CouchbaseとKafkaの新機能です。「xyz」と言うメッセージをCouchbaseバケットに挿入すると、コネクターはそれを取り出して、同じ名前の「xyz」のカフカトピックに挿入します。ここまでは順調ですね。しかし、ここで私はこのトピックを読んで別のトピックに "abc_123"と言うが、それは決して起こることはないカフカ消費者が走っている。主に私は動物園でこのエラーを見ています（これは私

1熱

2答えて

Windowsでドリルビットを配布し、シングルノードで起動する方法は？

私はZooKeeperのを始め、「zkServer.cmd」で正常に動作し、このようなcygwinのコマンドでドリルを開始したWindowsの分散モードでdrillbitのsevrerを開始したいが、うまくいきませんでした、：「SHのdrillbit.sh開始」サーバーはdrillbit.outログファイルにこのエラーを起動して、与えていない： C:\Drill/bin/runbit: line

0熱

1答えて

ストームトポロジをローカルで実行しているときにエラーが発生しています

localmodeでストームトポロジを実行してテストします。プロジェクトは本質的にカフカの噴出口からいくつかのログを採取し、いくつかの前処理操作を行い、スクリーン上に内容を印刷する。次は私のトポロジーコードです： import org.apache.storm.*; import org.apache.storm.generated.*; import org.apache.storm.ka

1熱

1答えて

その一部のノードから動物園のクラスタを回復する

ここに状況があります。私は zkノード、すなわち1,2,3,4,5,6を2つの異なる領域、すなわちA(1,2,3), B(4,5,6)に分けて得ました。ここでAがダウンし、Bからクラスタを回復したいと考えています。実行可能な2つの計画のどちらが1つですか？我々はそれとも私達はちょうど*.cfgファイルから他のすべての3つのノードを削除しそれを再起動することができ、このクラスタを再起動す