問題タブ [codahale-metrics]

私は、Kafka ストリームを取得し、ストリームに対して非常に基本的な変換を行い、データを DB (関連する場合は voltdb) に挿入する Spark Streaming プログラムに取り組んでいます。DB に行を挿入する速度を測定しようとしています。メトリクスは (JMX を使用して) 役立つと思います。ただし、カスタム メトリックを Spark に追加する方法が見つかりません。Spark のソース コードを調べたところ、このスレッドも見つかりましたが、うまくいきません。また、conf.metrics ファイルで JMX シンクを有効にしました。うまくいかないのは、JConsole でカスタム メトリックが表示されないことです。

スパーク ストリーミングにカスタム メトリックを (できれば JMX 経由で) 追加する方法を誰か説明してもらえますか? あるいは、DB (具体的には VoltDB) への挿入率を測定する方法を教えてください。Java 8でsparkを使用しています。

config.yml ファイルで dropwizard グラファイト メトリックス レポーターを構成しようとしました。

pom.xml の依存関係として、dropwizard-metrics と metrics-graphite の両方があります。レポーターに関する Application クラスまたは Configuration クラスには何もありません。私は、DropWizard が MetricRegistry とレポーターのすべての初期化と開始を処理するという印象を受けました。それでも、アプリケーションを実行すると、次のエラーが表示されます。

「グラファイト」が許容されるタイプとして取り上げられないのはなぜですか? 私は何が欠けていますか？

私は metrics-aspectj ライブラリを使用してきましたが、メソッドに注釈を付けてパフォーマンス メトリックを取得すると非常に便利であることがわかりました。最近、アノテーション付きのメソッドを持つクラスを拡張しようとしたときに壁にぶつかりました。ここに私が見るものがあります：

問題なく本番環境で Base クラスを使用しています。次に、このクラスを拡張する必要があります。

ご覧のとおり、method1() はオーバーライドされていません。しかし問題は、Derived クラスで method1() を使用するたびに、method1_aroundBody1$advice() で NullPointerException が発生することです。

私は AspectJ に詳しくないので、何が欠けているのか本当にわかりませんでした。アドバイスをいただければ幸いです。

ありがとう！

よろしく、 キャリー

Jersey 2.x (Jersey + Spring + tomcat) を使用して、REST ベースの Web サービスを公開しています。監視の目的で、サーバーからクライアントに送信される応答のサイズを経時的にキャプチャするヒストグラムを維持する必要があります。ジャージを使用してそれを行うことは可能ですか?

推奨される方法の1 つは、すべての (リクエストと) レスポンスを読み取り、レスポンスのサイズ情報を取得するサーブレット フィルター (Tomcat 用) を作成することです。ただ、フィルター導入による性能への影響が気になります。したがって、Jersey を使用したソリューションを探しています。

他の提案（方法）も高く評価されます。

サードパーティの統合 (rynatenney @EnableMetrics など) なしで注釈を使用して、プロジェクトの春の MVC プロジェクトに codahale-metrics 注釈を統合したいと考えています。

プロジェクトで codahale-metrics アノテーション (@Timed、@Metered など) を使用できるように、(@EnableMetrics) を使用せずに codahale-metrics を構成する別の方法はありますか?