Producteur : dans le champ d’application (déconseillé)

L’API Producer fournit des méthodes qui vous permettent d’envoyer des données d’une ServiceNow instance vers une rubrique Kafka.

Remarque :

Cette API est obsolète et remplacée par l’API ProducteurV2 - Dans le champ d’application .

Cette API nécessite le module d’extension Étape d’action ServiceNow Centre d'intégration - Kafka Producer (com.glide.hub.action_step.kafka) et est fournie dans l’espace de noms sn_ih_kafka .

Producteur : send(rubrique de chaîne, clé de chaîne, message de chaîne, booléen isSync)

Envoie le message spécifié à la rubrique Kafka spécifiée.

Tableau 1. Paramètres

Nom	Type	Description
sujet	Chaîne	Nom de la rubrique dans laquelle publier le message. Une rubrique stocke les messages du même type. Par exemple, une rubrique nommée Paiements peut stocker des messages sur les paiements récents. Lorsque vous entrez le nom de la rubrique, incluez tout ce qui vient après le préfixe du nom d’instance. Par exemple, si le nom complet de la rubrique est snc.<instancename>.sn_streamconnect.<topicname>, saisissez sn_streamconnect.<topicname> dans le champ de rubrique.
key	Chaîne	Nom de la clé d’une partition spécifique. Les rubriques peuvent être partitionnées. Les messages avec la même clé sont stockés dans la même partition. Par exemple, les messages de paiement avec une clé de juin seraient tous stockés dans la même partition de la rubrique Paiements.
message	Chaîne	Texte du message.
isSync	Booléen	Marqueur indiquant s’il faut exiger du flux qu’il attende la fin de l’étape avant de continuer. Valeurs valides : vrai : attendez que l’étape se termine avant de continuer le flux associé. faux : n’attendez pas que l’étape se termine avant de continuer le flux associé.

Tableau 2. Renvoie

Type	Description
Aucun

Cet exemple montre comment envoyer des informations sur l’incident modifié à la rubrique changed_incidents Kafka.

var message = {
  'number': current.number.toString(),
  'short_description': current.short_description.toString(),
  'caller_id': current.caller_id.getDisplayValue(),
  'priority': current.priority.toString(),
  'state': current.state.toString()
};

var producer = new sn_ih_kafka.Producer();
producer.send('changed_incidents', current.number.toString(), JSON.stringify(message), false);