Konfigurieren Sie einen Skript-Verbraucher

Verwenden Sie ein Skript zum Importieren und Verarbeiten von Daten aus Ihrer Kafka-Umgebung.

Vorbereitungen

• Erforderliche Rolle: integration_hub_admin
• Dieser Verbraucher benötigt ein Abonnement Stream Connect. Weitere Informationen finden Sie unter https://www.servicenow.com/now-platform/workflow-data-fabric.html.
• Das Plugin ServiceNow Stream Connect-Installationsprogramm [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 an Ihren Verbraucher definiert.

Diese Aufgabe umfasst die Erstellung des Verbrauchers. Anweisungen zum Erstellen eines Kafka-Streams finden Sie unter Erstellen Sie einen Kafka-Stream.

Prozedur

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

   Tabelle : 1. Kafka-Skript-Verbraucher

   Feld	Beschreibung
   Name	Name des Skriptverbrauchers
   Liefergarantie	Bei einem Knotenausfall Option zum Angeben der Zustellgarantie für eingehende Nachrichten. Wählen Sie eine der folgenden Antworten aus. Keine verlorenen, aber doppelte: Alle Nachrichten werden mindestens einmal zugestellt. Einige Nachrichten können mehrmals zugestellt werden. Einmal oder gar nicht: Eine Nachricht wird nur einmal 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 Nur-Text-Nachrichten. Dies ist das Standardformat. Codiert: Wählen Sie diese Option für Nachrichten im AVRO-Format Apache aus. Zum Konvertieren von Nur-Text-Nachrichten in ein AVRO-Format ist ein Schema erforderlich. Wählen Sie die Schemaregistrierung im Feld Schemaregistrierung aus. Weitere Informationen zu Schemas finden Sie unter Schemaverwaltung in Stream Connect.
   Ereignis-Verbraucher	Skript, das zum Verarbeiten der vom Kafka-Thema empfangenen Nachrichten verwendet wird.
   Anwendung	Anwendungsbereich für den Transformationszuordnungsverbraucher.
   Schemaregistrierung	Registrierung für das ausgewählte Schema. Wählen Sie eine der folgenden Antworten aus. Eigenständige Schemaregistrierung Confluent Schema-Registrierung Dieses Feld wird nur angezeigt, wenn das Serialisierungsformat auf Codiertfestgelegt ist. Wenn bei der Confluent Schema Registry die Schema-ID der empfangenen Nachricht nicht in der Schematabelle enthalten ist, importiert das System das Schema dynamisch über die konfigurierte 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.