Connexion au flux Guide de démarrage rapide

  • Rversion finale: Australia
  • Mis à jour 12 mars 2026
  • 17 minutes de lecture
  • 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.

    Connexion au flux dispose de deux producteurs qui envoient des ServiceNow données vers un environnement Kafka.
    • Étape du producteur Kafka Studio de workflow
    • ProducerV2 API
    La Connexion au flux comporte également quatre consommateurs qui récupèrent des données à partir d’un environnement Kafka.
    • Déclencheur de message Kafka dans Studio de workflow
    • Consommateur d’extraction de chargement de transformation (ETL)
    • Consommateur de carte de transformation
    • Consommateur de script

    Pour lier votre ServiceNow instance à un environnement Kafka, Connexion au flux utilise le fichier Service de messagerie Hermes. Le diagramme suivant montre chacun des producteurs et consommateurs et comment ils se connectent à votre environnement Kafka, présenté ici comme le site client, via Hermes.

    Figure 1. Producteurs et consommateurs de Connexion au flux
    Diagramme montrant les producteurs et les consommateurs de Stream Connect et comment ils se connectent à un environnement Kafka, décrit comme le « site client », via le Service de messagerie Hermes.

    Pour plus d’informations, reportez-vous à la Hermes Messaging Service section Utiliser Connexion au flux for Apache Kafka .

    Mise en route

    Pour représenter le site du client, ce guide utilise des Apache Kafka outils en ligne de commande exécutés sur votre ordinateur. Les paramètres de configuration utilisés avec cet outil peuvent être utilisés pour configurer n’importe quelle connexion client à la passerelle ADCv2 (Application Delivery Controller, version 2) à l’aide du protocole Kafka.

    Toutes les commandes données sont testées avec la version OpenSSL (LibreSSL 2.8.3) et Apache Kafka la version de distribution binaire kafka_2.13-3.4.0.tgz. Toutefois, toutes les commandes doivent fonctionner avec n’importe quelle version que vous avez dans votre environnement local.

    Étapes de démarrage rapide

    Ce guide de démarrage rapide comporte cinq étapes. Les étapes 1 et 2 expliquent comment configurer et tester une connexion à Hermes. Les étapes 3 à 5 vous montrent comment configurer et utiliser chacun des producteurs et consommateurs de Connexion au flux pour envoyer et recevoir des données.

    1. La passerelle ADCv2 utilise l’authentification réciproque pour authentifier les demandes, la première étape consiste donc à créer un magasin de clés et un magasin de confiance à utiliser avec votre client Kafka préféré. La page suivante vous montre comment créer les certificats requis : Établissez une connexion sécurisée au Service de messagerie Hermes.
    2. Après avoir configuré une connexion sécurisée à Hermes, 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.
    3. Maintenant, vous pouvez Utiliser le déclencheur de message Kafka et le consommateur de script pour utiliser des messages. La première partie de cette page vous montre comment utiliser le déclencheur de message Kafka pour Studio de workflow récupérer des messages de Kafka. La deuxième partie vous montre comment utiliser le consommateur de script pour récupérer des messages.
    4. Et Utiliser les consommateurs ETL et Carte de transformation pour importer des données. 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.
      Remarque :
      Pour utiliser le consommateur ETL, vous avez besoin d’un transformateur d’ensemble de données à importer robuste. De même, pour utiliser le consommateur de carte de transformation, vous avez besoin d’une carte de transformation.
    5. Enfin, vous pouvez Utilisez l’étape Kafka Producer et l’API ProducerV2 pour publier des messages. Cette page vous montre comment utiliser à la fois l’étape Studio de workflow Kafka Producer et l’API ProducerV2 pour transmettre des messages à Kafka.

    Établissez une connexion sécurisée au Service de messagerie Hermes

    Sécurisez vos rubriques Kafka en générant un certificat signé par une ServiceNow® instance.

    Avant de commencer

    La configuration nécessite une Service de messagerie Hermes coordination avec votre administrateur réseau et avec votre administrateur Kafka. Collaborez avec votre administrateur réseau pour obtenir les certificats de sécurité requis et ouvrir les ports requis. Travaillez avec votre administrateur Kafka pour vous assurer que votre environnement Kafka est correctement configuré et que vos applications peuvent s’y connecter à l’aide du Service de messagerie Hermes protocole Kafka standard.

    Assurez-vous que la configuration suivante est en place :

    • Le Service de messagerie Hermes est activé. Consultez Activating the Hermes Messaging Service.
    • Le module d’extension Cadre de travail de gestion des clés (com.glide.kmf.global) est activé.
    • La table Certificats [sys_kmf_certificate] contient un certificat d’autorité ServiceNow de certification racine de l’instance.
    • L’instance n’est pas configurée avec une URL personnalisée. Les URL personnalisées ne sont pas prises en charge avec le générateur de certificats PKI d’instance.

    Rôle requis : hermes_admin, sn_kmf.cryptographic_manager ou admin

    Pour plus de détails sur l’attribution des rôles KMF, reportez-vous à la section Roles installed with Key Management Framework.

    Procédure

    1. Accédez à la Tous > Générateur de certificats > Générateur de certificats PKI de l’instance.
    2. Facultatif : Contrôlez l’accès aux rubriques en configurant les listes de contrôle d’accès (ACL) au niveau de l’espace de noms ou de la rubrique.
      OptionDescription
      Appliquer des ACL aux espaces de noms
      1. Sélectionnez Configurer les ACL.
      2. Dans la boîte de dialogue ACL de rubrique, sélectionnez Espaces de noms.
      3. Entrez un espace de noms que vous souhaitez configurer.
      4. Définissez le niveau d’autorisation en sélectionnant Lecture seule ou Lecture/Écriture.
      5. Sélectionnez Ajouter.
      Appliquer des ACL à des rubriques définies
      1. Sélectionnez Configurer les ACL.
      2. Dans la boîte de dialogue ACL de rubrique, sélectionnez Rubriques définies.
      3. Entrez une rubrique existante que vous souhaitez configurer.
      4. Définissez le niveau d’autorisation en sélectionnant Lecture seule ou Lecture/Écriture.
      5. Sélectionnez Ajouter.
      Le porteur du certificat dispose d’un accès en lecture ou en lecture/écriture aux rubriques dans l’espace de noms ou dans la rubrique existante que vous avez sélectionnée.
    3. Configurez la sécurité pour le Service de messagerie Hermes.
      1. Revenez à la page Générateur de certificats PKI de l’instance.
      2. Saisissez un mot de passe de magasin de clé dans le champ Mot de passe du certificat .
      3. Sélectionnez Générer.
      Le système génère un certificat signé par l’instance dans la table Certificats [sys_kmf_certificate], crée un magasin de clés et crée un magasin de confiance.

      Si l’accès restreint pour l’appelant n’est pas autorisé pour le générateur de certificats IPKI, une erreur d’accès entre périmètres s’affiche. Contactez Service et assistance client pour obtenir de l’aide pour autoriser l’accès restreint pour l’appelant. Pour résoudre ce problème, Service et assistance client peut faire référence à source_scope=76f9d51369115083f4ea77aab1677cc0 dans la table Privilèges d’accès restreint pour l’appelant [sys_restricted_caller_access].

    4. Enregistrez une copie du magasin de clés en sélectionnant Télécharger le magasin de clés.
    5. Enregistrez une copie du magasin de clés de confiance en sélectionnant Télécharger le magasin de confiance.
    6. Copiez le magasin de clés et les fichiers du magasin de clés de confiance sur chaque client producteur et consommateur qui se connectera au Service de messagerie Hermes.

    Résultats

    Vous pouvez maintenant créer une connexion sécurisée au Service de messagerie Hermes.

    Remarque :
    Vous devez utiliser le magasin de clés que vous avez généré à l’aide du générateur de certificats PKI de l’instance pour vous connecter à Hermes. Les magasins de clés générés personnalisés qui ne sont pas créés conformément à la ServiceNow documentation ne sont pas pris en charge.

    Testez la connexion à Hermes via la passerelle ADCv2

    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.

    Avant de commencer

    • Rôle requis : integration_hub_admin

    Procédure

    1. Téléchargez et installez Apache Kafka.
      1. Télécharger le Apache Kafka binaires.
      2. Décompressez le package Kafka en exécutant la commande suivante :
        tar -zxvf kafka_2.13-3.1.2.tgz
    2. Accédez au répertoire Kafka en exécutant la commande suivante :
      cd kafka_2.13-3.1.2
    3. Configurez un producteur.
      1. Ouvrez le fichier config/producer.properties .
      2. Configurez les propriétés SSL suivantes :
        security.protocol=SSL
        
        ssl.truststore.password=<truststore password>
        
        ssl.truststore.location=<path to truststore.p12>
        
        ssl.truststore.type=PKCS12
        
        ssl.keystore.password=<keystore password>
        
        ssl.keystore.location=<path to keystore.p12>
        
        ssl.keystore.type=PKCS12
        
        ssl.key.password=<keystore password>
        Remplacez les variables d’espace réservé suivantes :
        • <mot de passe du magasin de confiance> avec votre mot de passe du magasin de confiance.
        • <chemin d’accès à truststore.p12> avec le chemin d’accès à votre fichier de magasin de confiance.
        • < mot de passe du keystore > avec votre mot de passe keystore.
        • <chemin d’accès à keystore.p12> avec le chemin d’accès à votre fichier keystore.
      Après avoir suivi les étapes 1 à 3, vous devez avoir téléchargé Apache Kafka et configuré le fichier producer.properties correctement. Toutes les commandes données dans les étapes suivantes doivent s’exécuter dans le Apache Kafka répertoire de base.
    4. Copiez le fichier config/producer.properties dans config/bootcamp.properties.
      Cet exemple utilise bootcamp comme nom générique.
      cp config/producer.properties config/bootcamp.properties
    5. Utilisez la commande suivante pour répertorier les rubriques.
      bin/kafka-topics.sh --list --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
      Assurez-vous de remplacer <nom d’instance> par le nom de votre instance.
      S’il existe des rubriques dans l’instance, elles doivent être répertoriées ici.

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

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

    Avant de commencer

    • Rôle requis : integration_hub_admin
    • La première partie de cette section vous montre comment utiliser le déclencheur de message Kafka pour Studio de workflow consommer des messages. Pour plus d’informations sur le déclencheur, reportez-vous à la section Create a flow with a Kafka Message trigger.
    • La deuxième partie de cette section vous montre comment utiliser le consommateur de script pour utiliser les messages. Pour plus d'informations, consultez Configurer un consommateur de script.

    Procédure

    1. Créez une rubrique pour utiliser les messages.
      1. Utilisez la commande suivante pour créer une rubrique dans Hermes.
        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 à Tous > Centre d'intégration > Connexion au flux > Rubriques.
        Remarque :
        La création d’une rubrique prend environ 10 minutes.
    2. Créez un déclencheur de flux pour utiliser les messages de la rubrique.
      1. Accédez à la Tous > Automatisation des processus > Concepteur de flux.
      2. Sélectionner Créer > Flux.
      3. Sur le formulaire des propriétés du flux, donnez un nom à votre flux, puis entrez Soumettre.
        Cet exemple utilise le nom Consommateur Topic1.
      4. Dans la section Déclencheur, sélectionnez Ajouter un déclencheur, puis Message Kafka comme type de déclencheur.
        Le message Kafka est le type de déclencheur du flux.
      5. Sélectionnez la rubrique Rubrique 1.
        Sélectionnez rubrique1 pour le champ Rubrique.

        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 secondaire > Logique de flux > Pour 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 secondaire > Action > Cœur de ServiceNow > Journal.
      9. Faites glisser la pastille de données Payload vers le champ Message , puis sélectionnez Terminé.
        Rubrique 1 : déclencheur de flux de consommateur.
      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 sur le flux créé ci-dessus.
        Création d’un nouvel enregistrement de paramètre pour activer la génération de rapports pour le flux.
      13. Revenez à votre flux et sélectionnez Activer.
      14. Pour afficher votre abonnement à la rubrique, accédez à Tous > Centre d'intégration > Connexion au flux > Abonnements.
        L’abonnement à la rubrique topic1.
    3. Publiez des messages dans la rubrique à l’aide de l’outil en 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 de test 1
        • Message de test 2
        • Message de test 3
        Vous devriez recevoir les messages dans environ une minute.
      2. Revenez au flux et sélectionnez Exécutions.
        Sélectionnez Exécutions pour accéder à la vue d’exécution du flux.
      3. Ouvrez l’exécution du flux.
        Détails d’exécution du flux.
      4. Pour afficher les statistiques de cet abonnement, accédez à Tous > Centre d'intégration > Connexion au flux > Abonnements, ouvrez l’abonnement et accédez à la vue des statistiques.
        Statistiques Kafka pour l’abonnement.
    4. Créez un consommateur de script pour utiliser les messages de la rubrique.
      1. Accédez à la Centre d'intégration > Consommateurs > Consommateurs de script.
      2. Sélectionnez Nouveau.
      3. Dans le champ Nom , saisissez un nom pour votre consommateur de script.
        Cet exemple utilise Consommateur de la rubrique 1.
      4. Définissez le script pour enregistrer 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));
         }
        
        Consommateur de script Kafka affichant le script dans le champ Consommateur d’événement.
      5. Enregistrez le formulaire.
      6. Dans la section Liens connexes, sélectionnez Nouveau pour ajouter un flux Kafka afin de consommer les messages.
      7. Sur le formulaire Flux Kafka, définissez les valeurs de champ suivantes.
        • Nom du flux Rubrique1.
        • Rubrique à la rubrique créée précédemment, rubrique 1.
        • Concurrence max. sur 1.
        • Commencez à consommer pour 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.
        L’enregistrement Kafka Stream.
      8. Sélectionnez le lien Activer sous Liens connexes.
        Vous devriez pouvoir voir l’abonnement activé.
      9. Pour afficher les messages, accédez à Tous > Journaux système > Journal système et filtrer les messages commençant par le message reçu.
        Liste des messages reçus.
      10. Vous devriez voir tous les messages après 1 minute.

    Utiliser les consommateurs ETL et Carte de transformation pour importer des données

    Utilisez des définitions ETL et des 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.

    Avant de commencer

    • Rôle requis : integration_hub_admin
    • La première partie de cette section vous montre comment utiliser le consommateur ETL pour consommer des messages. Pour utiliser le consommateur ETL, vous avez besoin d’un transformateur d’ensemble de données à importer robuste.
    • La deuxième partie de cette section vous montre comment utiliser un consommateur de carte de transformation pour consommer des messages. Pour utiliser Consommateur de carte de transformation, vous avez besoin d’une carte de transformation.

    Procédure

    1. Créez une rubrique pour utiliser ETL et transformer les messages de consommateur de la carte.
      1. Utilisez la commande suivante pour créer une rubrique dans Hermes.
        Dans cet exemple, le nom de la rubrique est topic2.
        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>.topic2
        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 à Tous > Centre d'intégration > Connexion au flux > Rubriques.
        Remarque :
        La création d’une rubrique prend environ 10 minutes.
    2. Créez un consommateur ETL pour utiliser les données de la rubrique.
      1. Accédez à la Tous > Centre d'intégration > Consommateurs > Consommateur ETL.
      2. Sélectionnez Nouveau.
      3. Sur le formulaire Consommateur Kafka, entrez un nom dans le champ Nom .
        Cet exemple utilise le nom Importation de membres.
      4. Pour le transformateur d’ensemble d’importation robuste déposé, sélectionnez un transformateur d’ensemble d’importation robuste existant.
        Pour le transformateur d’ensemble d’importation robuste, sélectionnez-en un qui n’utilise pas l’option de stockage des données dans une seule colonne. Pour pouvoir voir les messages, assurez-vous que l’option Détaillé est activée sur le transformateur d’ensemble d’importation robuste.
      5. Désélectionnez l’option Données dans une colonne unique .
        Cette option ne doit être sélectionnée que pour les tables d’ensembles de données à importer avec des données dans une seule colonne.
      6. Définissez le mappage de colonnes sur Étiquette.

        Cela signifie que les clés JSON du message d’entrée sont mappées aux étiquettes de colonne de la table Jeu d’importation.

        Formulaire Consommateur ETL Kafka.
      7. Enregistrez le formulaire.
      8. Créer un flux Kafka pour le consommateur.
      9. Sur le formulaire Flux Kafka, définissez les valeurs de champ suivantes.
        • Nom du flux Rubrique2.
        • Rubrique de la rubrique créée précédemment, rubrique 2.
        • Concurrence max. sur 1.
        • Commencer à consommer pour les messages reçus après la première activation.
        • Gestion des messages à optimiser automatiquement.
      10. Sélectionnez le lien Activer sous Liens connexes.

        Vous devriez pouvoir voir l’abonnement activé.

        Exemple de formulaire de flux Kafka pour la rubrique 2.
    3. Publier des messages sur la rubrique 2.
      1. Exécutez la commande suivante pour publier des messages dans la rubrique 2.
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --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.

      2. Envoyez le message JSON suivant.
        {"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
        Vous pouvez envoyer ce message avec n’importe quelle valeur, mais la clé de message JSON doit correspondre aux étiquettes de la table Import Set.
      3. Revenez au consommateur ETL que vous avez créé.

        Au bout d’une minute environ, les données devraient avoir été importées via le jeu d’importation.

        Formulaire Consommateur Kafka avec l’onglet Jeux d’importation renseigné.
      4. Pour afficher des informations détaillées sur le jeu d’importation, sélectionnez le numéro de jeu d’importation.
        Vue détaillée du jeu d’importation.
      5. Pour afficher des informations détaillées sur une ligne de jeu d’importation, sélectionnez le numéro de ligne de jeu d’importation.
        Vue détaillée de la ligne de jeu d’importation
    4. Créez un consommateur de carte de transformation pour consommer des données.
      1. Accédez à la Tous > Centre d'intégration > Consommateurs > Consommateur de carte de transformation.
      2. Sélectionnez Nouveau.
      3. Sur le formulaire Consommateur de carte de transformation, entrez un nom dans le champ Nom .
      4. Pour le champ Carte de transformation , sélectionnez une carte de transformation existante.
        Formulaire Consommateur de carte de transformation.
      5. Enregistrez le formulaire.
      6. Créer un flux Kafka pour le consommateur.
      7. Sur le formulaire Flux Kafka, définissez les valeurs de champ suivantes.
        • Nom du flux de carte de transformation.
        • Rubrique de la rubrique créée précédemment, rubrique 2.
        • Concurrence max. sur 1.
        • Commencer à consommer pour les messages reçus après la première activation.
        • Gestion des messages à optimiser automatiquement.
      8. Sélectionnez le lien Activer sous Liens connexes.

        Vous devriez pouvoir voir l’abonnement activé.

        Formulaire Kafka Stream pour le consommateur de carte de transformation avec des informations sur l’abonnement.
    5. Publier des messages sur la rubrique 2.
      1. Exécutez la commande suivante pour publier des messages dans la rubrique 2.
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --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.

      2. Envoyez le message JSON suivant.
        {"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
        Vous pouvez envoyer ce message avec n’importe quelle valeur, mais la clé de message JSON doit correspondre aux étiquettes de la table Import Set.
      3. Accédez au consommateur de carte de transformation que vous avez créé.
        Au bout d’une minute environ, les données devraient avoir été importées via le jeu d’importation.
      4. Pour afficher des informations détaillées sur le jeu d’importation, sélectionnez le numéro de jeu d’importation comme indiqué à l’étape 3d ci-dessus.

    Utilisez l’étape Kafka Producer et l’API ProducerV2 pour publier des messages

    Transmettre les données par ServiceNow push vers Hermes afin que les consommateurs Kafka puissent les lire.

    Avant de commencer

    • Rôle requis : integration_hub_admin
    • La première partie de cette section vous montre comment utiliser l’étape Créateur Kafka pour Studio de workflow publier des messages sur Hermès. Pour en savoir plus sur cette étape, reportez-vous à la section Kafka Producer step.
    • La deuxième partie de cette section vous montre comment utiliser l’API ProducerV2 pour publier des messages. Pour plus d’informations, consultez API ProducerV2.
    • Pour recevoir tous les messages, vous devez exécuter deux consommateurs pour des centres de données différents. Consultez Consume test messages from a Hermes topic using the Kafka client pour en savoir plus.

    Procédure

    1. Démarrez deux consommateurs pour recevoir des messages.
      1. Exécutez les commandes suivantes à partir de la ligne de commande pour recevoir les messages.
        bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4100,<instance name>.service-now.com:4101,<instance name>.service-now.com:4102,<instance name>.service-now.com:4103
        bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4200, <instance name>.service-now.com:4201, <instance name>.service-now.com:4202, <instance name>.service-now.com:4203
        Assurez-vous de remplacer <nom d’instance> par le nom de votre instance.
    2. Publiez des messages à partir de l’instance à l’aide d’une étape de flux.
      1. Accédez à la Tous > Automatisation des processus > Concepteur de flux.
      2. Créer une action en sélectionnant Créer > Action.
      3. Dans le formulaire Propriétés de l’action, donnez un nom à votre action, puis sélectionnez Soumettre.
        Cet exemple utilise le nom Éditeur de message.
      4. Ajoutez une étape de producteur Kafka à l’action.

        Pour ajouter une étape d’action, sélectionnez le signe plus entre les champs Entrées et Évaluation des erreurs dans le Plan d’action.

        Ajoutez l’étape Producteur Kafka à l’action.
      5. Dans l’étape, définissez le champ Rubrique sur rubrique1.
      6. Dans le champ Message , saisissez un message.

        Vous n’avez pas besoin de modifier d’autres champs.

        Renseignez les champs de l’étape Producteur Kafka.
      7. Sélectionnez Enregistrer pour enregistrer l’action.
      8. Sélectionnez le bouton Test pour tester l’action.
        Le test de l’action publie le message dans la rubrique.
      9. Pour afficher le message, accédez aux consoles de ligne de commande créées à l’étape 1.
        Le message doit être présent dans l’un des terminaux.
    3. Publier des messages à partir de l’instance à l’aide d’un script.
      1. Exécutez le script suivant en utilisant l’arrière-plan de scripts pour publier des messages dans cette rubrique à partir de l’instance.
        var producer = new sn_ih_kafka.ProducerV2();
        producer.send('<sys id of the topic record>', gs.generateGUID(), 'Test message from ServiceNow', false, null);
        
        Assurez-vous de remplacer <ID système de l’enregistrement de rubrique> par le sys_id de l’enregistrement de rubrique.
      2. Pour afficher le message, accédez aux consoles de ligne de commande créées à l’étape 1.
        Le message doit être présent dans l’un des terminaux.