apache-zookeeper

0熱

1答えて

ことができない私は、私は与えられたコンシューマ・グループのための情報を取得するためにオフセットZooKeeperのCLIを使用してい飼育係</p> <p>を使用していますZooKeeperのCLI

を使用してカフカconsumergroupのための情報をオフセットフェッチ。以下はは細かい Command: get /consumers/[ConsumerGroup]/offsets/[TopicName] o/p : 0:1640002 cZxid = 0x304ca036d ctime = Fri Dec 23 17:29:30 UTC 2016 mZxid = 0x30af

0熱

1答えて

Restart Kubernetes petsetは永続ボリュームを消去します

glusterfs永続ボリュームを使用している3つのzookeepers petsetを実行しています。あなたがペットセットを始めたのが初めてならば、すべてが良いことです。私の要件の1つは、petsetが強制終了された場合、再起動後も同じ永続ボリュームを使用することです。私が直面している問題は、petsetを再起動すると、永続ボリューム内の元のデータが消去されるということです。では、手動でその

1熱

1答えて

カフカのブローカーの接続文字列を取得するには

私はカフカを初めて利用しています。メッセージを送受信するためのコンシューマクラスとプロデューサクラスを実装しようとしました。ブローカのIPとポートのリストである両方のクラスに対して、bootstrap.serversを,で区切って設定する必要があります。例えば、 producerConfig.put("bootstrap.servers", "172.16.20.207:9946,

1熱

1答えて

newAPIHadoopRDDの読み込みにHBaseが多すぎる（主な原因はDns.reverseDns）

最近、SparkとHBaseでクラスタをテストしていました。 HBaseテーブルからレコードを読み込むためにnewAPIHadoopRDDを使用していました。新しいAPIHadoopRDDが遅すぎることがわかりました。時間はリージョンサーバーの数に比例していました。 17/03/02 22:00:30 DEBUG AbstractRpcClient: Use SIMPLE authenticati

2熱

2答えて

春のブートクラウド+リボン+ Feign + Hystrix +飼い葉桶：何が起こっているのは再試行ですか？

私は+ 装う + Hystrixリボンを使用して春ブート（1.5.1）といくつかのサービスを作成しようとしています（と私のサービスの発見は、ばねboot-ある飼育係）とIドン'はズールを使用します。私はそれが道を以下に動作するはず思考（ナイーブ）であった：は（@FeignClientによる注釈付き）装う方法を呼び出す - 送信するので、もしそれが、リボンによって何らかの方法でバランス負荷である

1熱

1答えて

飼い葉桶での点滅：進行中の指導者選挙のためにサービスが一時的に利用できません。リフレッシュしてください

高可用性モードでflinkクラスタを実行します。そこで私はJobManager High Availabilityの設定をflinkの設定ファイルにしました。 start-zookeeper-quorum.shを使用してzookeeper quorumを起動すると、2台のマシンで2台のzookeerperサーバー（ピア）を起動できます。しかし、2人のJobManagersでFlinkクラスタを起動

1熱

1答えて

Kafka on Cloudera - テスト= TOPIC_AUTHORIZATION_FAILED

CDH 5.3.6から5.10.0にアップグレードし、カフカのトピックに書き込もうとするとエラーが発生しました。すべてのデフォルト設定があり、SSLまたはKerberos認証は有効になっていません。コンソールプロデューサーを使用してトピックの1つに書き込むとき、このエラーが発生します。 /usr/bin/kafka-console-producer --broker-list = myhost1.

1熱

1答えて

複数のzkCliコマンドを実行する

zkCliに対して2つのコマンドを一緒に実行したい。 zkCli addauth digest username:password && zkCli setAcl /zknode-path world:anyone:crdwa すでにzknodeのACL値を設定していて、元に戻したいと思っています。しかし、このコマンドを実行すると、認証は有効ではありません。どのように1つのセッションでこれらの

0熱

2答えて

追加のApache Kafkaブローカーを作成できません

私はApache Kafka websiteの指示に従っています。私はすべてのインスタンスを変更するので、これはケースではありません 0.0.0.0:9092: Address already in use. ：私は次のエラーを取得する sudo bin/kafka-server-start.sh config/server-1.properties ：私はコマンドを使用して、ブローカを起

0熱

1答えて

Zookeeperのf-syncの問題によりKafkaのタイムアウトが発生する

Zookeeper & Kafkaの場合、16コアのVMに16ノードの& 16 GB RAMを搭載したVMに1つのノードをインストールしようとしています。 Zookeeperはf-syncの問題を表示しており、設定された6000msのタイムアウト時間の後にkafkaがタイムアウトを与えます。追加情報：飼育係バージョン：3.4.6-1569965 カフカバージョン：エントリ以下2.11-0.9.