Konfigurieren Sie einen Skriptverbraucher

Verwenden Sie ein Skript, um Daten aus Ihrer Kafka-Umgebung zu importieren und zu verarbeiten.

Vorbereitungen

• Erforderliche Rolle: Integration_Hub_admin
• Dieser Verbraucher erfordert einen Stream Connect Abonnement. Weitere Informationen finden Sie unter https://www.servicenow.com/now-platform/workflow-data-fabric.html.
• Die ServiceNow Stream Connect-Installationsprogramm [Plugin com.glide.hub.stream_connect.installer] ist erforderlich.

Warum und wann dieser Vorgang ausgeführt wird

Um einen Verbraucher zu konfigurieren, müssen Sie zwei Datensätze erstellen.

1. Der Verbraucherdatensatz, der angibt, wie Daten importiert und verarbeitet werden.
2. Ein Datensatz für den Kafka-Stream, der den Datenstrom für Ihren Verbraucher definiert.

Diese Aufgabe deckt die Verbrauchererstellung ab. Anweisungen zum Erstellen eines Kafka-Streams finden Sie unter Erstellen Sie einen Kafka-Stream.

Prozedur

1. Navigieren zu Alle > IntegrationHub > Verbraucher > Skript-Verbraucheran.
2. Wählen Sie Neu.
3. Füllen Sie die Felder des Formulars aus.

   Tabelle : 1. Skript-Verbraucher

   Feld	Beschreibung
   Name	Name des Skriptverbrauchers.
   Liefergarantie	Bei einem Knotenfehler Option zum Festlegen der Zustellgarantie für eingehende Nachrichten. Wählen Sie eine der folgenden Antworten aus. Keine verlorenen, sondern Duplikate : Alle Nachrichten werden mindestens einmal zugestellt. Einige Nachrichten werden möglicherweise mehrmals zugestellt. Einmal oder überhaupt nicht : Eine Nachricht wird nicht mehrmals zugestellt. Einige Nachrichten werden möglicherweise überhaupt nicht zugestellt.
   Serialisierungsformat	Das Serialisierungsformat für die Nachricht. Wählen Sie eine der folgenden Antworten aus. Nur-Text : Wählen Sie diese Option für alle nur-Text-Nachrichten aus. Dies ist das Standardformat. Codiert : Wählen Sie diese Option für Nachrichten in einem aus Apache Avro-Format. Das Konvertieren von nur-Text-Nachrichten in ein Avro-Format erfordert ein Schema. Wählen Sie die Schemaregistrierung in aus Schemaregistrierung Feld. Weitere Informationen zu Schemas finden Sie unter Schemaverwaltung in Stream Connect.
   Ereignis-Verbraucher	Skript, das zum Verbrauchen der vom Kafka-Thema empfangenen Nachrichten verwendet werden soll.
   Anwendung	Anwendungsbereich für den Verbraucher der Transformationszuordnung.
   Schemaregistrierung	Registrierung für das ausgewählte Schema. Wählen Sie eine der folgenden Antworten aus. Eigenständige Schemaregistrierung Confluent-Schemaregistrierung Dieses Feld wird nur angezeigt, wenn Serialisierungsformat Ist auf festgelegt Codiert . Wenn sich die Schema-ID der empfangenen Nachricht für die Confluent-Schemaregistrierung nicht in der Schematabelle befindet, importiert das System das Schema dynamisch mithilfe der konfigurierten REST-Verbindung.

4. Wählen Sie Speichern.

Beispiel

Dieses Beispiel zeigt ein Beispielskript für die Verarbeitung von Nachrichten.

(function process(messages) {
 // Add your code here to consume kafka messages 
 // sample message [ { 'key' : 'message_key' , 'message' : 'message' , 'headers' : [ { 'key' : 'header_key' , 'value' : 'header_value' } ] } ] 

 for (var i = 0; i < messages.length; i++) {
     var message = JSON.parse(messages[i].message);
     gs.info('Number ' + message.number + ', short description ' + message.short_description +
         ', headers ' + JSON.stringify(messages[i].headers));
 }
})(messages);

Nächste Maßnahme

Erstellen Sie einen Kafka-Stream Für diesen Verbraucher. Nachdem der Stream aktiviert wurde, können Sie Nachrichten aus Ihrer Kafka-Umgebung empfangen.