Accéder au contenu principal Passer au contenu complémentaire

Configurer les composants

Procédure

  1. Double-cliquez sur le cTimer pour afficher sa vue Basic settings dans l'onglet Component. Laissez les paramètres par défaut des options ci-dessous.
  2. Double-cliquez sur le premier cSetBody nommé SetBodyAsJsonString pour ouvrir sa vue Basic settings dans l'onglet Component.
  3. Sélectionnez Constant dans la liste déroulante Language et saisissez la chaîne de caractères JSON "{\"my_field1\": 1,\"my_field2\": 72438939,\"my_field3\": \"my demo Test message\"}" dans le champ Expression comme corps de message.
  4. Double-cliquez sur le premier cProcessor nommé ConvertBodyToAvro pour ouvrir sa vue Basic settings dans l'onglet Component.
  5. Dans le champ Code, configurez le code Java pour convertir le corps du message (string JSON) en Avro Record. 
    Object body = exchange.getMessage().getBody();
exchange.getMessage().setBody(KafkaAvroConverterBean.jsonStringToAvro(body));
  6. Cliquez sur l'onglet Advanced settings et saisissez l'instruction suivante dans le champ Import. Assurez-vous de remplacer local_project par le nom du projet Talend. 
    import org.example.local_project.beansjar.kafka_avro_beans.KafkaAvroConverterBean;
  7. Double-cliquez sur le second cProcessor nommé ConvertBodyToJsonString pour ouvrir sa vue Basic settings dans l'onglet Component.
  8. Dans le champ Code, configurez le code Java suivant pour convertir le corps du message (Avro Record) en string JSON. 
    Object body = exchange.getMessage().getBody();
exchange.getMessage().setBody(KafkaAvroConverterBean.avroToJsonString(body));
  9. Cliquez sur l'onglet Advanced settings et saisissez l'instruction suivante dans le champ Import. Assurez-vous de remplacer local_project par le nom du projet Talend. 
    import org.example.local_project.beansjar.kafka_avro_beans.KafkaAvroConverterBean;
  10. Double-cliquez sur le cKafka nommé SendMessageToKafka pour ouvrir sa vue Basic settings dans l'onglet Component.
  11. Dans le champ Broker List, saisissez "localhost:9092".
    Dans le champ Topic, saisissez "demo.AVRO".
    Dans le champ Serializer Class, saisissez "org.example.local_project.beansjar.kafka_avro_beans.KafkaAvroSerializerBean". Assurez-vous de remplacer local_project par le nom du projet Talend.
    Laissez les paramètres par défaut pour les autres options.
  12. Cliquez sur l'onglet Advanced settings. Dans le champ Kafka Properties, ajoutez un paramètre du nom "schemaRegistryURL" et de valeur "localhost:8081".
  13. Double-cliquez sur le second cKafka nommé ReceiveMessageFromKafka pour ouvrir sa vue Basic settings dans l'onglet Component.
  14. Dans le champ Broker List, saisissez "localhost:9092".
    Dans le champ Topic, saisissez "demo.AVRO".
    Laissez les paramètres par défaut pour les autres options.
  15. Cliquez sur l'onglet Advanced settings. Dans le champ Kafka Properties, ajoutez deux paramètres, respectivement nommés "schemaRegistryURL" et "valueDeserializer", et dont la valeur est respectivement "localhost:8081" et "org.example.local_project.beansjar.kafka_avro_beans.KafkaAvroDeserializerBean". Assurez-vous de remplacer local_project par le nom du projet Talend.
  16. Laissez les valeurs par défaut des paramètres du composant cLog afin d'enregistrer les échanges de messages.
  17. Appuyez sur les touches Ctrl+S pour sauvegarder votre Route.

Cette page vous a-t-elle aidé ?

Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – dites-nous comment nous améliorer !

Laissez vos commentaires ici