問題タブ [kairosdb]

kafkaメッセージを kairosDB に直接ストリーミングするためにkafka-kairosdbプラグインを使用しています。

フォルダーにプラグインを作成して正常に追加しました/lib。ログから、プラグインが実行されており、kafka トピックに接続されていることがわかります。このトピックにメッセージを送信した後、プラグインによって続行されず、そのままのようですfor (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream)。

デフォルトのstringparserのトピック名がkafkaのトピックに一致することを除いて、構成は何も変更しませんでした。

アプリケーションを kairosDB でテストしたいのですが、外部の kairosDB サーバーを使用したくありません。

テスト用に埋め込まれた KairosDB (H2 のようなメモリ内 DB) を作成することは可能ですか?

KairosDB バージョン 1.1.3-1。

私はdataPointsを持ってい[time, name, key, value]ます。最初に and でグループ化し、次に結果を集計し、次に再度グループ化してから再度集計することは可能nameですkeyかkey?

だから基本的に：

1. +のすべての値とname1+key1のすべての値name2key1
2. それぞれを平均して集計 (期間 10 秒)
3. 集計結果のグループ化key1(ここで結果を結合したい)
4. 指定された結果を合計で集計します (同じ期間、10 秒)。