Relier les composants - Cloud - 8.0

Kafka
Version
Cloud
8.0
Language
Français
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
Module
Studio Talend
Content
Création et développement > Systèmes tiers > Composants Messaging (Intégration) > Composants Kafka
Gouvernance de données > Systèmes tiers > Composants Messaging (Intégration) > Composants Kafka
Qualité et préparation de données > Systèmes tiers > Composants Messaging (Intégration) > Composants Kafka

Procédure

  1. Dans la perspective Integration du Studio, créez deux Jobs Standards vides à partir du nœud Job Designs dans la vue Repository.
  2. Dans l'espace de modélisation graphique, saisissez le nom du composant à utiliser et sélectionnez ce composant dans la liste qui s'affiche. Dans ce scénario, les composants sont : un tKafkaInput, un tJavaRow et un tLogRow pour le Job de lecture et un tFixedFlowInput, untJavaRow et untKafkaOutput pour le Job d'écriture.
    Le composant tFixedFlowInput est utilisé pour charger les données d'exemple dans le flux de données. Dans un scénario réel, vous pouvez utiliser d'autres composants, comme le tFileInputDelimited, seul ou avec un tMap, à la place du tFixedFlowInput, afin de construire un processus sophistiqué pour préparer vos données au traitement.
  3. Pour le Job de lecture, reliez le tKafkaInput au tJavaRow et reliez le tJavaRow au tLogRow à l'aide d'un lien Row > Main.
  4. Pour le Job d'écriture, reliez le tFixedFlowInput au tJavaRow et reliez le tJavaRow au tKafkaOutput à l'aide d'un lien Row > Main.

Résultats

Les Jobs de lecture et d'écriture sont configurés.