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

Rversion finale: Washingtondc

Mis à jour 1 févr. 2024

2 minutes de lecture

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

Avant de commencer

Rôle requis : integration_hub_admin
Cette page fait partie du Connexion au flux pour Apache Kafka Guide de démarrage rapidefichier .
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 Kafka Producer pour Concepteur de flux publier des messages dans Hermes. Pour en savoir plus sur l’étape, reportez-vous 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 différents centres de données. 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 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.
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 des 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.