Utilisation de l'évier Apache Flume Kafka sur Cygnus

Question

Je souhaite utiliser l'évier Kafka fourni avec Apache Flume. Cependant, il semble que le paquetage cygnus-common soit basé sur Apache Flume 1.4 alors que le puits de Kafka a été ajouté autour d'Apache Flume 1.7. Si j'ajoute le fichier jar Kafka à la bibliothèque cygnus-common, il échoue car le noyau cygnus-common est obsolète.

Il est donc possible d'utiliser la dernière version du canal (1.8) au lieu de cygnus-common avec les bibliothèques cygnus-ngsi? Dans ce cas, je peux basculer entre l'évier Apache Flume Kafka et le NGSIKafkaSink?

Answer 1

Je suis Andrés de l'équipe UPM Fiware. Vous avez raison de souligner que Fiware Cygnus est basé sur Apache Flume 1.4 alors, répondre à votre question, existe une forte probabilité que les puits utilisés dans une version postérieure de Flume ne soient pas compatibles avec Cygnus. Nous travaillons sur une mise à jour de Cygnus afin d'utiliser la dernière version du canal et de gérer les notifications NGSIV2 de manière native mais c'est un travail en cours et qui prend du temps. Je pense qu'actuellement la seule façon de travailler avec Cygnus et kafka sink est d'utiliser le GE fourni par FIWARE dans ses versions correspondantes.

I