Ersteller – Scoped (veraltet)

Die Producer -API stellt Methoden bereit, mit denen Sie Daten aus einer ServiceNow -Instanz in ein Kafka-Thema verschieben können.

Hinweis:

Diese API ist veraltet und wurde durch die ProducerV2 : Scoped -API ersetzt.

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

Producer – send(String topic, String key, String message, Boolean isSync)

Sendet die angegebene Nachricht an das angegebene Kafka-Thema.

Tabelle : 1. Parameter

Name	Typ	Beschreibung
Thema	Zeichenfolge	Name des Themas, in dem die Nachricht veröffentlicht werden soll. In einem Thema werden Nachrichten desselben Typs gespeichert. Beispielsweise können in einem Thema mit dem Namen Zahlungen Nachrichten zu den letzten Zahlungen gespeichert werden. Wenn Sie den Themennamen eingeben, schließen Sie alles ein, was nach dem Instanznamenpräfix kommt. Zum Beispiel, wenn der vollständige Themenname snc lautet.<instancename> .sn_streamconnect.<topicname> , geben Sie sn_streamconnect ein. im Themenfeld.
key	Zeichenfolge	Name des Schlüssels für eine bestimmte Partition. Themen können partitioniert werden. Nachrichten mit demselben Schlüssel werden in derselben Partition gespeichert. Zum Beispiel werden Zahlungsnachrichten mit dem Schlüssel Juni alle in derselben Partition des Themas „Zahlungen“ gespeichert.
Nachricht	Zeichenfolge	Nachrichtentext.
isSync	Boolean	Kennzeichnung, die angibt, ob der Flow auf den Abschluss des Schritts warten muss, bevor er fortfahren kann. 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.

Tabelle : 2. Ergebnisse

Typ	Beschreibung
Keine

Dieses Beispiel zeigt, wie geänderte Incident-Informationen an das Kafka-Thema „change_incidents“ 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 producer = new sn_ih_kafka.Producer();
producer.send('changed_incidents', current.number.toString(), JSON.stringify(message), false);