0

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

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

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

4

1 に答える 1