Verwendung von Apache Flume Kafka Waschbecken auf Cygnus

Question

Ich möchte die Kafka-Spüle verwenden, die mit Apache Flume kommt. Es scheint jedoch, dass das Cygnus-Common-Paket auf Apache Flume 1.4 basiert, während die Kafka-Senke um Apache Flume 1.7 herum hinzugefügt wurde. Wenn ich die Kafka-Jar-Datei zur Cygnus-Common-Bibliothek hinzufüge, scheitert sie, weil der Cygnus-Common-Core veraltet ist.

So ist es möglich, die neueste Gerinne Version (1.8) anstelle von Cygnus-Common mit Cygnus-NGSI-Bibliotheken zu verwenden? In diesem Fall kann ich zwischen Apache Flume Kafka Sink und dem NGSIKafkaSink wechseln?

Answer 1

Ich bin Andrés vom UPM Fiware Team. Sie haben Recht damit, dass Fiware Cygnus auf Apache Flume 1.4 basiert. Daher besteht auf Ihre Frage eine hohe Wahrscheinlichkeit, dass die in einer späteren Version von Flume verwendeten Senken nicht mit Cygnus kompatibel sind. Wir arbeiten an einem Update von Cygnus, um die neueste Version von Gerinne zu verwenden und auch die NGSIV2-Benachrichtigungen auf native Weise zu verwalten, aber es ist ein work in progress und braucht Zeit. Ich denke, momentan ist die einzige Möglichkeit, mit Cygnus und kafka sink zu arbeiten, die Verwendung des GE von FIWARE in seinen entsprechenden Versionen.

I