ProducteurV2 - Dans le champ d’application

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

Remarque :

Cette API nécessite un Connexion au flux abonnement. Pour plus d'informations, consultez https://www.servicenow.com/now-platform/workflow-data-fabric.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, clé de chaîne, message de chaîne, booléen isSync, en-têtes d’objets, schemaID de chaîne)

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].
clé	Chaîne	Nom de la clé d’une partition spécifique dans la rubrique.
message	Chaîne	Texte du message.
isSync	Booléen	Marqueur indiquant s’il faut exiger du script qu’il attende la fin de la méthode d’envoi 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é.
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. 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
Néant

Cet exemple montre comment envoyer des informations d’incident modifiées à la rubrique Kafka avec une sys_id de 75135aa2ff0311105cf343d0653bf155, à l’aide d’un schéma avec une 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');