apache-storm

1熱

1答えて

なぜApache Storm KafkaSpoutはカフカのトピックから非常に多くのアイテムを放出していますか？

私はカフカとストームに問題があります。私が設定しているKafkaSpoutの設定に問題がある場合、または私が正しく肯定応答していないかどうか、この時点ではわかりません。私は50個のアイテムを私のカフカトピックにキューイングしましたが、私のスパウトは1300個以上のタプルを放出しました。また、Spoutは、ほとんどすべてが「失敗」していると報告しています。トポロジは、実際にそれが成功したデータベー

0熱

1答えて

ストーム0.10.x（KafkaSpout）を使用しているKafka 0.10.xトピックから消耗します

このフォーラムで質問するのが正しいかどうかはわかりません。ストームKafkaSpoutコネクタを使用してカフカのトピックから消費していました。これまではうまくいっていました。今度はバージョン0.10.xで実行されている同じStorm envからアップグレードされたバージョン0.10.xを持つ新しいKafkaクラスタに接続することになっています。ストームのドキュメント（http://storm.a

0熱

1答えて

与えられたフィールドを持つすべてのタプルが処理されたかどうかを確かめるための嵐ボルト

私は複数のタプルをペアレル数8で処理して処理した後、idを出して、次のボルトにインデックスを付けて、処理され、通知が送信されます。どのようにそれを行うことができますか？嵐は既にそれのためのimplementatinoを持っていますか？

0熱

1答えて

Storm UIでKerberosセットアップにエラーが発生しました

Apache StormのActive DirectoryでKerberos認証をセットアップしました。ケルベロス設定後、スーパバイザとNimbusデーモンはうまく動作しています。 ui.filter: "org.apache.hadoop.security.authentication.server.AuthenticationFilter" ui.filter.params : {‘typ

0熱

1答えて

コンシューマより多くのパーティションがあるとメッセージが消えますか？

私は使用しているkafkaスパウトに15人のエグゼキュータがあり、70人のエグゼキュータがないのでメッセージを失う可能性があるので、3つのレプリカと70のパーティションを持つカフカのトピックからメッセージを読んでいます。？ kafkaのすべてのメッセージが消費者によって受信されたことを確認するにはどうすればよいですか？は

0熱

1答えて

Filter-Interceptor-Kafkaのトピック

こんにちは、解析エンジンを構築して、クライアントが使用しているurl \ eventsのリアルタイム解析を決定し、apiのパフォーマンスをログに記録しようとしています。続きは私が実装する予定ですロジックです： 1. MVC-インターセプタを使用してそれらをを傍受するためのロジックを持って再利用可能なjarファイルとしてURLを 2.コードフィルタを傍受するためのフィルタを作成します。 3.イン

0熱

1答えて

ストームメッセージが失敗しました

最近私は本当に奇妙な問題を抱えました。ストームクラスターには3台のマシンがあります。トポロジ構造は、このようなものです。Kafka Spout A - > Bolt B - > Bolt C例外をスローする可能性はありますが、すべてのボルトですべてのタプルを確認しました。タプルをackしてください）。しかし、ここでは奇妙なことが起こります。スパウトのログを印刷します。スパウトによってすべてのタプ

0熱

1答えて

Apache Storm UIで複数のスーパーバイザを実行しているときのエラー

私たちは、1台のマシンで動物園を、2台目にはNimbus、次に別のマシンで2人のスーパーバイザ（ワーカー）を実行しています。 ZookeperはWindows 7上で動作しており、その他はすべてCent OS上で動作しています。今の問題は、私たちは光背を実行しているマシン上で嵐のUIを実行すると、それは（ランダムにページをリフレッシュするには2つのスーパーバイザ間で変化する）のみの単一super

0熱

1答えて

特定のスーパーバイザでトポロジを開始するようにStorm Nimbusに指示する方法はありますか？

私は嵐のクラスタ（1.0.2バージョン）をセットアップし、5つのトポロジが起動しています。それらのうち2つは、CPU集約型トポロジとメモリ集約型トポロジです。トポロジを送信している間、私はこれらの2つのプロセッサをストーム・ニンバス・クラスタ内の別々のスーパーバイザで実行する必要があります。負荷とリソースが共有されるようにします。しかし、トポロジを停止して再起動すると、2CPUとメモリを消費するプ