Utilisez l’étape Créateur Kafka 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
• Cette page fait partie de la section Connexion au flux Guide de démarrage rapide.
• Ce document vous montre comment publier des messages via votre connexion à Hermes. Pour configurer et tester votre connexion, reportez-vous à la section Établissez une connexion sécurisée au Service de messagerie HermesTest de la connexion à Hermes via la passerelle ADCv2.
• La première partie de cette page vous montre comment utiliser l’étape Studio de workflow Créateur Kafka pour publier des messages sur Hermès. Pour en savoir plus sur cette étape, reportez-vous à la section .
• La deuxième partie de cette page 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 à 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.

      

   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.

      

   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.