ProducerV2 - Inclus dans le champ d’application

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

Remarque :

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

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

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

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 que la méthode d’envoi se termine avant de continuer. Valeurs valides : true : attendez la fin de l’étape avant de poursuivre le flux associé. false : 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 comme des 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.

Tableau 2. Renvoie

Type	Description
Néant

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

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);