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

Rversion finale: Xanadu

Mis à jour 1 août 2024

2 minutes de lecture

Transférez les données vers ServiceNow Hermes afin que les consommateurs Kafka puissent les lire.

Avant de commencer

Rôle requis : integration_hub_admin
Cette page fait partie de la Connexion au flux Guide de démarrage rapidesection .
Ce document vous montre comment publier des messages via votre connexion à Hermes. Pour configurer et tester votre connexion, consultez Set up a secure connection to the Hermes Messaging Service et Test de la connexion à Hermes via la passerelle ADCv2.
La première partie de cette page vous montre comment utiliser l’étape Producteur Kafka pour Studio de workflow publier des messages dans Hermes. Pour en savoir plus sur cette étape, reportez-vous à la section Kafka Producer step.
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

Démarrez deux consommateurs pour recevoir des messages.

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.

Publiez des messages à partir de l’instance à l’aide d’une étape de flux.
1. Accédez à la Tout > 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, attribuez un nom à votre action, puis sélectionnez Soumettre.
  Cet exemple utilise le nom Message Publisher.
4. Ajoutez une étape Producteur Kafka à l’action.
  
  Pour ajouter une étape d’action, sélectionnez le signe plus entre les entrées et l’évaluation de l’erreur dans le plan d’action.
5. Dans l’étape, définissez le champ Rubrique sur topic1.
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 se trouver dans l’un des terminaux.
Publier des messages à partir de l’instance à l’aide d’un script.
1. Exécutez le script suivant à l’aide de l’arrière-plan 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);
```
  Veillez à 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 se trouver dans l’un des terminaux.