kafkaメッセージを kairosDB に直接ストリーミングするためにkafka-kairosdbプラグインを使用しています。
フォルダーにプラグインを作成して正常に追加しました/lib
。ログから、プラグインが実行されており、kafka トピックに接続されていることがわかります。このトピックにメッセージを送信した後、プラグインによって続行されず、そのままのようですfor (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream)
。
デフォルトのstringparserのトピック名がkafkaのトピックに一致することを除いて、構成は何も変更しませんでした。