FIWARE Elasticsearch/KibanaへのCygnusシンク？

Question

私は現在、作業の流れを抱えている：

Fiwareオリオン - > Fiwareシグナス - >カフカ - > Logstash - > Elasticsearch - > Kibana

私はElasticsearchするシグナスから直接データをプッシュしたいですすでにシンクが利用可能ですか？ https://flume.apache.org/releases/content/1.3.0/apidocs/org/apache/flume/sink/elasticsearch/ElasticSearchSink.html

シグナスのためにそれを使用して簡単になる場合、私は思っていた：

アンApacheの水路/ Elasticsearchはすでに存在して沈みますか？

Answer 1

Cygnus 1.5.0（含まれています）まで、そのようなシンクは、他のFlumeシンクと同様に、Cygnusエージェント構成で完全に使用できます。

ネイティブEventオブジェクトの使用を内部でNGSIEvent個のものに内部的に置き換えたため、1.6.0（これが最後のバージョンです）以降は使用できません。理由：

• Eventは、本文のローバイトのセットです。
Event
• NGSIEventを継承し（オブジェクトなど）のヘッダの集合体の既に解析されたバージョンとnull（この最後の部分を指す体の生バイトの配列では、互換性を回避するものですネイティブのFlumeシンク）。

とにかく、これは修正するのが簡単です。新しいバージョンNGSIEventは、解析されたバージョンの本体と本体自体を生のバイトとして扱います。