Schéma Avro personnalisé dans Kafka et limites
Lorsque vous créez un jeu de données Kafka, vous pouvez renseigner un schéma Avro personnalisé utilisé lors de la lecture/l'écriture depuis le topic sélectionné.
Vous trouverez ci-dessous une liste des différentes actions que vous pouvez effectuer dans Talend Pipeline Designer et leurs conséquences sur la lecture/l'écriture depuis/vers le jeu de données Kafka.
Action sur le jeu de données | Conséquence dans l'application |
---|---|
Extraire un échantillon d'un nouveau topic (sans enregistrements) d'un jeu de données Kafka ne possédant pas de schéma |
L'échantillon est vide |
Extraire un échantillon d'un nouveau topic (sans enregistrements) d'un jeu de données Kafka possédant un schéma valide |
L'échantillon est vide |
Extraire un échantillon d'un topic existant d'un jeu de données Kafka ne possédant pas de schéma |
L'échantillon est vide |
Extraire un échantillon d'un topic existant d'un jeu de données Kafka possédant un schéma compatible binairement |
L'échantillon est affiché |
Extraire un échantillon d'un topic existant d'un jeu de données Kafka possédant un schéma non compatible |
Une erreur est affichée |
Exécuter un pipeline écrivant dans un nouveau topic d'un jeu de données Kafka ne possédant pas de schéma |
Le pipeline est exécuté sans erreur, les enregistrements continuent d'utiliser le schéma du dernier composant avant le composant Kafka |
Exécuter un pipeline écrivant dans un nouveau topic d'un jeu de données Kafka possédant un schéma compatible avec les données du pipeline |
Le pipeline est exécuté sans erreur, les enregistrements continuent d'utiliser le schéma du jeu de données |
Exécuter un pipeline écrivant dans un nouveau topic d'un jeu de données Kafka possédant un schéma non compatible avec le pipeline |
Le pipeline échoue et retourne une exception |
Exécuter un pipeline lisant depuis un topic existant d'un jeu de données Kafka possédant un schéma compatible binairement |
Le pipeline est exécuté sans erreur |
Exécuter un pipeline lisant depuis un topic existant d'un jeu de données Kafka possédant un schéma non compatible |
Le pipeline échoue et retourne une exception |