ProducerV2 : Scoped

Die ProducerV2 -API stellt Methoden zum Veröffentlichen von Nachrichten aus Ihrer ServiceNow -Instanz in einem Kafka-Thema bereit.

Hinweis:

Diese API ist Teil von Stream Connect für Apache Kafka, für das ein Stream Connect für Apache Kafka -Abonnement erforderlich ist. Weitere Informationen finden Sie unter https://www.servicenow.com/products/automation-engine.html.

Diese API erfordert das Plugin „ ServiceNow IntegrationHub Action Step – Kafka Producer“ (com.glide.hub.action_step.kafka) und wird im Namespace sn_ih_kafka ausgeführt.

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

Sendet die angegebene Nachricht an das angegebene Kafka-Thema.

Tabelle : 1. Parameter

Name	Typ	Beschreibung
topicSysID	Zeichenfolge	Sys_id des Themas, in dem die Nachricht veröffentlicht werden soll. Themen werden in der Tabelle „Kafka-Themen“ [sys_kafka_topic] gespeichert.
key	Zeichenfolge	Name des Schlüssels für eine bestimmte Partition im Thema.
Nachricht	Zeichenfolge	Nachrichtentext.
isSync	Boolean	Kennzeichnung, die angibt, ob das Skript auf den Abschluss der Sendemethode warten muss, bevor fortgesetzt wird. Gültige Werte: true: Warten Sie, bis der Schritt abgeschlossen ist, bevor Sie den zugehörigen Flow fortsetzen. false: Warten Sie nicht auf den Abschluss des Schritts, bevor Sie den zugehörigen Flow fortsetzen.
headers	Objekt	Header für die Nachricht, definiert als Schlüssel-Wert-Paare. "headers": { "<key>": "<value>" } Beispiel: var headers = { "origin": "sn_business_rule" }; Schlüssel: Zeichenfolge. Name der Kopfzeile. Wert: Zeichenfolge. Wert der Kopfzeile.

Tabelle : 2. Ergebnisse

Typ	Beschreibung
Keine

Dieses Beispiel zeigt, wie geänderte Incident-Informationen an das Kafka-Thema mit der sys_id 75135aa2ff0311105cf343d0653bf155 gesendet werden.

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