ProducerV2 - Dans le champ d’application

L’API ProducerV2 fournit des méthodes pour publier des messages à partir de votre ServiceNow instance dans une rubrique Kafka.

Remarque :

Cette API nécessite un Connexion au flux abonnement. Pour plus d'informations, consultez https://www.servicenow.com/products/automation-engine.html.

Cette API nécessite le module d’extension ServiceNow Stream Connect Installer (com.glide.hub.stream_connect.installer) et s’exécute dans l’espace de noms sn_ih_kafka .

ProducerV2 - send(String topicSysID, String key, String message, Boolean isSync, Object headers, String schemaID)

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

Tableau 1. Paramètres

Nom	Type	Description
topicSysID	Chaîne	Sys_id de la rubrique dans laquelle publier le message. Les rubriques sont stockées dans la table Rubriques Kafka [sys_kafka_topic].
key	Chaîne	Nom de la clé pour une partition spécifique dans la rubrique.
message	Chaîne	Texte du message.
isSync (en anglais seulement)	Booléen	Marqueur indiquant s’il faut exiger que le script attende la fin de la méthode d’envoi 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é.
en-têtes	Objet	En-têtes du message, définis sous forme de paires clé-valeur. "headers": { "<key>": "<value>" } Par exemple, var headers = { « origin » : « sn_business_rule » } ; clé : chaîne de caractères. Nom de l’en-tête. valeur : chaîne. Valeur de l’en-tête.
ID du schéma	Chaîne	Sys_id de l’enregistrement de schéma. Requis si vous utilisez un schéma pour convertir des messages en texte brut en messages Avro et inversement. Les schémas sont stockés dans la table Schémas de connexion au flux [stream_connect_schema]. Pour plus d'informations, consultez Schema management in Stream Connect.

Tableau 2. Renvoie

Type	Description
Aucun

Cet exemple montre comment envoyer des informations d’incident modifiées à la rubrique Kafka avec un sys_id de 75135aa2ff0311105cf343d0653bf155, à l’aide d’un schéma avec un sys_id de f9d083f3ff610210ef7343d3653bf12e.

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 headers = {
    'origin': 'sn_business_rule'
};

var producer = new sn_ih_kafka.ProducerV2();
producer.send('75135aa2ff0311105cf343d0653bf155', gs.generateGUID(), JSON.stringify(message), false, headers, 'f9d083f3ff610210ef7343d3653bf12e');