在Cygnus上使用Apache Flume Kafka接收器

我想使用Apache Flume附帶的Kafka接收器。然而，cygnus-common軟件包似乎基於Apache Flume 1.4，而Kafka sink則是在Apache Flume 1.7的基礎上添加的。如果我將卡夫卡jar文件添加到cygnus-common庫中，它會失敗，因爲cygnus-common核心已過時。在Cygnus上使用Apache Flume Kafka接收器

因此，有可能使用最新的flume版本（1.8）而不是cygnus-common與cygnus-ngsi庫？在這種情況下，我可以在使用Apache Flume Kafka接收器和NGSIKafkaSink之間切換？

來源

2017-10-21 alstack

我是來自UPM Fiware團隊的Andrés。您正確地指出，Fiware Cygnus基於Apache Flume 1.4，因此，在回答您的問題時，很有可能在後期版本的Flume中使用的接收器與Cygnus不兼容。我們正在研究Cygnus的更新，以便使用最新發布的flume，並以本地方式管理NGSIV2通知，但這是一項正在進行的工作，需要時間。我認爲目前與Cygnus和卡夫卡接收器合作的唯一方式是使用FIWARE在其相應版本中提供的GE。

來源

2018-01-18 09:44:45 anmunoz

在Cygnus上使用Apache Flume Kafka接收器

回答

相關問題