---
sourceDocument: Xanadu : créer des intégrations avec des applications
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/fr-FR/xanadu/integrate-applications

 Release :

    - xanadu

ft:locale :

    - fr-FR

ft:publication_title :

    - Xanadu : créer des intégrations avec des applications

ft:clusterId :

    - crint

bundleId :

    - crint

workflow :

    - Creator


---

# Utiliser le déclencheur de message Kafka et le consommateur de script pour utiliser les messages

# Utiliser le déclencheur de message Kafka et le consommateur de script pour utiliser les messages {#ariaid-title1}

* Rversion finale: Xanadu
* 
* Mis à jour 1 août 2024
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 3 minutes de lecture

Récupérez les messages Hermes avec le déclencheur de message Kafka dans Studio de workflow et le consommateur de script.

## Avant de commencer

* Rôle requis : integration_hub_admin
* Cette page fait partie de la [Connexion au flux Guide de démarrage rapide](https://servicenow-prod.fluidtopics.net/pSOwxsIatwhV7e9pvIEh0w "Ce guide de démarrage rapide vous donne une vue d’ensemble de la configuration et de l’utilisation de chacun des six producteurs et consommateurs de Stream Connect pour échanger des données entre votre ServiceNow instance et un environnement Kafka.")section .
* Ce document vous montre comment utiliser des messages via votre connexion à Hermes. Pour configurer et tester votre connexion, consultez [Set up a secure connection to the Hermes Messaging Service](https://www.servicenow.com/docs/access?context=set-up-secure-connection-to-hermes&version=xanadu&pubname=xanadu-servicenow-platform&ft:locale=en-US) et [Test de la connexion à Hermes via la passerelle ADCv2](https://servicenow-prod.fluidtopics.net/5IC9ajft_b3sWyh~hQ4hug "Vérifiez que le magasin de clés et le magasin de clés de confiance ont été correctement générés en testant la connexion à Hermes via la passerelle ADCv2.").
* La première partie de cette page vous montre comment utiliser le déclencheur de message Kafka pour Studio de workflow consommer des messages. Pour en savoir plus sur le déclencheur, reportez-vous à la section [Create a flow with a Kafka Message trigger](https://www.servicenow.com/docs/access?context=create-flow-kafka&version=xanadu&pubname=xanadu-build-workflows&ft:locale=en-US). Pour en savoir plus sur les flux et les configurer, reportez-vous Studio de workflow à la section .
* La deuxième partie de cette page vous montre comment utiliser le consommateur de script pour utiliser des messages. Pour plus d'informations, consultez [Configurer un consommateur de script](https://servicenow-prod.fluidtopics.net/mIO~0meRKemEm44b_K_ZEw "Utilisez un script pour importer et traiter les données de votre environnement Kafka.").
{#use-kafka-trigger-script-consumer__ul_gbw_h5n_cyb}

## Procédure

1. Créez une rubrique pour utiliser des messages.
   1. Utilisez la commande suivante pour créer une rubrique dans Hermès.  

          bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1

      Assurez-vous de remplacer `<nom d'instance>` par le nom de votre instance.
   2. Pour afficher la rubrique, connectez-vous à l'instance et accédez à ToutCentre d'intégrationConnexion au fluxRubriques.  
      Remarque :  
      La création d'une rubrique prend environ 10 minutes.
   {#use-kafka-trigger-script-consumer__substeps_ir5_fzd_yxb}
2. Créez un déclencheur de flux pour utiliser les messages de la rubrique.
   1. Accédez à la ToutAutomatisation des processusConcepteur de flux.
   2. Sélectionner CréerFlux.
   3. Dans le formulaire Propriétés du flux, saisissez un nom pour votre flux, puis saisissez Soumettre.  
      Cet exemple utilise le nom <kbd class="ph userinput">Consommateur Topic1</kbd>.
   4. Dans la section déclencheur, sélectionnez Ajouter un déclencheur, puis sélectionnez Message Kafka comme type de déclencheur.  
   5. Sélectionnez la rubrique Topic1.  

      Vous pouvez utiliser l'icône de loupe pour afficher la liste des rubriques disponibles.
   6. Dans la section Actions du flux, accédez à Ajouter une action, une logique de flux ou un flux secondaireLogique de fluxPour chaque.
   7. Faites glisser la pastille de données Messages vers le champ Éléments , puis sélectionnez Terminé.
   8. Dans la section Actions du flux, accédez à Ajouter une action, une logique de flux ou un flux secondaireActionCœur de ServiceNowJournal.
   9. Faites glisser la pastille de données Payload vers le champ Message , puis sélectionnez Terminé.  
   10. Enregistrez le déclencheur de flux.
   11. Accédez à la table Paramètres \[sys_flow_execution_setting\] pour activer la génération de rapports pour ce flux.
   12. Créez une nouvelle entrée et activez la génération de rapports pour le flux créé ci-dessus.  
   13. Revenez à votre flux et sélectionnez Activer.
   14. Pour afficher votre abonnement à une rubrique, accédez à ToutConcentrateur d'intégrationConnexion au fluxAbonnements.  
   {#use-kafka-trigger-script-consumer__substeps_vrn_szd_yxb}
3. Publiez des messages dans la rubrique à l'aide de l'outil de ligne de commande Kafka.
   1. Exécutez la commande suivante pour publier des messages dans la rubrique.  

          bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

      Assurez-vous de remplacer `<nom d'instance>` par le nom de votre instance.  
      Cette commande vous invite à entrer des messages. Ajoutez quelques exemples de messages. Cet exemple utilise les messages suivants.
      * Message test 1
      * Message test 2
      * Message test 3
      {#use-kafka-trigger-script-consumer__ul_arc_54m_2yb}Vous devriez recevoir les messages dans environ une minute.
   2. Revenez au flux et sélectionnez Exécutions.  
   3. Ouvrez l'exécution du flux.  
   4. Pour afficher les statistiques de cet abonnement, accédez à ToutConcentrateur d'intégrationConnexion au fluxAbonnements, ouvrez l'abonnement et accédez à la vue Statistiques.  
   {#use-kafka-trigger-script-consumer__substeps_nrq_gkq_yxb}
4. Créez un consommateur de script pour utiliser les messages de la rubrique.
   1. Accédez à la Centre d'intégrationConsommateursConsommateurs de script.
   2. Sélectionnez Nouveau.
   3. Dans le champ Nom , entrez un nom pour votre consommateur de script.  
      Cet exemple utilise <kbd class="ph userinput">le consommateur Topic1</kbd>.
   4. Définissez le script pour consigner le message en ajoutant la logique suivante dans la zone de script.  

          for (var i = 0; i < messages.length; i++) {
                gs.info('Received message ' + JSON.stringify(messages[i].message));
           }

   5. Enregistrez le formulaire.
   6. Dans la section Liens connexes, sélectionnez Nouveau pour ajouter un flux Kafka afin d'utiliser les messages.
   7. Sur le formulaire Flux Kafka, définissez les valeurs de champ suivantes.  
      * Nom du <kbd class="ph userinput">flux Topic1</kbd>.
      * Rubrique de la rubrique créée précédemment, topic1.
      * Concurrence maximale à <kbd class="ph userinput">1</kbd>.
      * Commencer la consommation vers Tous les messages stockés dans la rubrique. Cette option vous permet de lire les messages déjà publiés dans cette rubrique.
      * Gestion des messages à optimiser automatiquement.
      {#use-kafka-trigger-script-consumer__ul_pbp_rqm_2yb}  
   8. Sélectionnez le lien Activer sous Liens connexes.  
      Vous devriez être en mesure de voir l'abonnement activé.
   9. Pour afficher les messages, accédez à ToutJournaux systèmeJournal système et filtrez les messages qui commencent par Message reçu.  
   10. Vous devriez voir tous les messages après 1 minute.
   {#use-kafka-trigger-script-consumer__substeps_mm5_rkq_yxb}

## Que faire ensuite

[Utiliser les consommateurs ETL et de carte de transformation pour importer des données](https://servicenow-prod.fluidtopics.net/k9ZshvOGBJf4sAenPatawg "Utilisez les définitions ETL et les cartes de transformation pour traiter les événements Kafka. Les définitions ETL et les cartes de transformation spécifient la logique de transformation à utiliser lors de l’extraction des données via les importations planifiées. Vous pouvez utiliser les mêmes définitions ETL et cartes de transformation pour transformer les événements reçus via Kafka.").