Apache Flumeの使用CygnusのKafka sink

Question

Apache Flumeに付属のKafkaシンクを使用したいと思います。しかし、cygnus共通のパッケージはApache Flume 1.4に基づいているのに対して、KafkaのシンクはApache Flume 1.7の周りに追加されているようです。 cygnus-commonライブラリにKafka jarファイルを追加すると、cygnus-commonコアが古くなっているので失敗します。

したがって、cygnus-ngsiライブラリでcygnus-commonの代わりに最新のflumeバージョン（1.8）を使用することは可能ですか？その場合、私はApache Flume KafkaシンクとNGSIKafkaSinkを切り替えることができますか？

Answer 1

私はUPM Fiware TeamのAndrésです。あなたは正しくFiware CygnusがApache Flume 1.4に基づいていることを指摘しています。あなたの質問に答えると、Flumeの後方バージョンで使用されるシンクがCygnusと互換性がない可能性が高いです。 flumeの最新リリースを使用し、NGSIV2通知をネイティブな方法で管理するために、Cygnusのアップデートに取り組んでいますが、進行中の作業であり、時間がかかります。私は現在、Cygnusとkafka sinkで動作する唯一の方法は、対応するバージョンでFIWAREが提供するGEを使用することだと思います。