Apache Apex - Kafka 0.9 sujets sécurisés pour kafka

Question

Quelqu'un peut-il m'aider à comprendre ?

Apache Apex dispose-t-il d'un opérateur d'entrée kafka intégré pour lire les sujets Kafka 0.9 secure kafka ?

Answer 1

Apex supporte Kafka 0.9. Vous pouvez lire les sujets Kafka en utilisant KafkaSinglePortInputOperator. Vous trouverez ci-dessous un lien vers un exemple d'utilisation de cet opérateur.

https://github.com/DataTorrent/examples/blob/master/tutorials/kafka/src/main/java/com/example/myapexapp/KafkaApp.java

Answer 2

Oui, Apache Apex dispose d'opérateurs pour lire depuis des clusters kafka 0.9 sécurisés.

Je vous suggère de construire votre jar malhar à partir de github repo car il y a des corrections récentes ajoutées sur la connexion aux clusters kafka 0.9 sécurisés. Vérifiez le lien ci-dessous.

https://github.com/apache/apex-malhar