Producteur - inclus dans le champ d’application (obsolète)

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

Remarque :

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

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

Producteur – send(Sujet de chaîne, clé de chaîne, message de chaîne, isSync booléen)

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 vers laquelle publier le message. Une rubrique stocke des messages du même type. Par exemple, une rubrique nommée Paiements peut stocker des messages sur les paiements récents. Lorsque vous saisissez 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 rubrique.
key	Chaîne	Nom de la clé pour 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 seront tous stockés dans la même partition de la rubrique Paiements.
message	Chaîne	Texte du message.
isSync (en anglais seulement)	Booléen	Marqueur indiquant s’il faut exiger que le flux attende la fin de l’étape avant de continuer. Valeurs valides : vrai : attendez la fin de l’étape avant de poursuivre le flux associé. faux : n’attendez pas la fin de l’étape avant de poursuivre le flux associé.

Tableau 2. Renvoie

Type	Description
Aucun

Cet exemple montre comment envoyer des informations d’incident modifiées à 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);