在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之间切换?
答
我是来自UPM Fiware团队的Andrés。您正确地指出,Fiware Cygnus基于Apache Flume 1.4,因此,在回答您的问题时,很有可能在后期版本的Flume中使用的接收器与Cygnus不兼容。我们正在研究Cygnus的更新,以便使用最新发布的flume,并以本地方式管理NGSIV2通知,但这是一项正在进行的工作,需要时间。我认为目前与Cygnus和卡夫卡接收器合作的唯一方式是使用FIWARE在其相应版本中提供的GE。
I