---
sourceDocument: Xanadu: Integrationen mit Anwendungen erstellen
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/de-DE/xanadu/integrate-applications

 Release :

    - xanadu

ft:locale :

    - de-DE

ft:publication_title :

    - Xanadu: Integrationen mit Anwendungen erstellen

ft:clusterId :

    - crint

bundleId :

    - crint

workflow :

    - Creator


---

# Verwenden Sie den Kafka-Nachrichtenauslöser und den Skriptverbraucher, um Nachrichten zu verbrauchen

# Verwenden Sie den Kafka-Nachrichtenauslöser und den Skriptverbraucher, um Nachrichten zu verbrauchen {#ariaid-title1}

* Freigeben Version: Xanadu
* 
* Aktualisiert 1. August 2024
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 3 Minuten Lesedauer

Rufen Sie Nachrichten aus Hermes mit dem Auslöser „Kafka-Nachricht" in Workflow-Studio und dem Skript-Verbraucher ab.

## Vorbereitungen

* Erforderliche Rolle: integration_hub_admin
* Diese Seite ist Teil von [Stream Connect Schnellstarthandbuch](https://servicenow-prod.fluidtopics.net/c5L2Dtl2Ys3f_j1UGtvy0Q "Diese Schnellstartanleitung gibt Ihnen einen Überblick über die Einrichtung und Verwendung der sechs Stream Connect-Ersteller und -Verbraucher für den Datenaustausch zwischen Ihrer Instanz ServiceNow und einer Kafka-Umgebung.").
* In diesem Dokument erfahren Sie, wie Sie Nachrichten über Ihre Verbindung zu Hermes verbrauchen. Informationen zum Einrichten und Testen Ihrer Verbindung finden Sie unter [Set up a secure connection to the Hermes Messaging Service](https://www.servicenow.com/docs/access?context=set-up-secure-connection-to-hermes&version=xanadu&pubname=xanadu-servicenow-platform&ft:locale=en-US) und [Verbindung mit Hermes über das ADCv2-Gateway testen](https://servicenow-prod.fluidtopics.net/m8xUkhIPdH1NF69iyyy9nw "Stellen Sie sicher, dass der Schlüsselspeicher und der Truststore ordnungsgemäß generiert wurden, indem Sie die Verbindung zu Hermes über das ADCv2-Gateway testen.").
* Im ersten Teil dieser Seite erfahren Sie, wie Sie den Kafka-Nachrichtenauslöser in Workflow-Studio verwenden, um Nachrichten zu verbrauchen. Weitere Informationen zum Auslöser finden Sie unter [Create a flow with a Kafka Message trigger](https://www.servicenow.com/docs/access?context=create-flow-kafka&version=xanadu&pubname=xanadu-build-workflows&ft:locale=en-US). Weitere Informationen zu Workflow-Studio und zum Konfigurieren von Flows finden Sie unter .
* Im zweiten Teil dieser Seite erfahren Sie, wie Sie mit dem Skriptverbraucher Nachrichten verbrauchen. Weitere Informationen finden Sie unter [Konfigurieren Sie einen Skript-Verbraucher](https://servicenow-prod.fluidtopics.net/KXbzUyQmL~enSXpq8J6FyA "Verwenden Sie ein Skript zum Importieren und Verarbeiten von Daten aus Ihrer Kafka-Umgebung.").
{#use-kafka-trigger-script-consumer__ul_gbw_h5n_cyb}

## Prozedur

1. Erstellen Sie ein Thema, um Nachrichten zu verarbeiten.
   1. Verwenden Sie den folgenden Befehl, um ein Thema in Hermes zu erstellen.  

          bin/kafka-topics.sh --create --command-config config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002, <instance name>.service-now.com:4003 --topic snc.<instance name>.topic1

      Ersetzen Sie unbedingt\<instance name\> mit dem Namen Ihrer Instanz.
   2. Um das Thema anzuzeigen, melden Sie sich bei der Instanz an, und navigieren Sie zu AlleIntegrationHubStream ConnectThemen.  
      Hinweis:  
      Das Erstellen eines Themas dauert ungefähr 10 Minuten.
   {#use-kafka-trigger-script-consumer__substeps_ir5_fzd_yxb}
2. Erstellen Sie einen Flow-Auslöser, um Nachrichten aus dem Thema zu verarbeiten.
   1. Navigieren zu AlleProzessautomatisierungFlow Designer.
   2. Auswahlvorgang Neu erstellenFlow.
   3. Geben Sie im Formular „Flow-Eigenschaften" einen Namen für Ihren Flow ein, und geben Sie dann Absendenein.  
      In diesem Beispiel wird der Name <kbd class="ph userinput">Topic1 Consumer</kbd>verwendet.
   4. Wählen Sie im Abschnitt „Auslöser" Auslöser hinzufügenund dann Kafka-Nachricht als Auslösertyp aus.  
   5. Wählen Sie das Thema 1 aus.  

      Sie können das Lupensymbol verwenden, um die Liste der verfügbaren Themen anzuzeigen.
   6. Navigieren Sie im Abschnitt Aktionen des Flows zu Aktion, Flow-Logik oder Subflow hinzufügenFlow-LogikFor Each.
   7. Ziehen Sie die Datenpille Nachrichten in das Feld Elemente, und wählen Sie Fertigaus.
   8. Navigieren Sie im Abschnitt Aktionen des Flows zu Aktion, Flow-Logik oder Subflow hinzufügenAktionServiceNow CoreProtokoll.
   9. Ziehen Sie die Datenpille Nutzlast in das Feld Nachricht, und wählen Sie Fertigaus.  
   10. Speichern Sie den Flow-Auslöser.
   11. Wechseln Sie zur Tabelle „Einstellungen" \[sys_flow_execution_setting\], um die Berichterstellung für diesen Flow zu aktivieren.
   12. Erstellen Sie einen neuen Eintrag, und aktivieren Sie die Berichterstellung für den oben erstellten Flow.  
   13. Navigieren Sie zurück zu Ihrem Flow, und wählen Sie Aktivierenaus.
   14. Um Ihr Themenabonnement anzuzeigen, navigieren Sie zu AlleIntegrations-HubStream ConnectAbonnements.  
   {#use-kafka-trigger-script-consumer__substeps_vrn_szd_yxb}
3. Veröffentlichen Sie mit dem Kafka-Befehlszeilentool Nachrichten im Thema.
   1. Führen Sie den folgenden Befehl aus, um Nachrichten für das Thema zu veröffentlichen.  

          bin/kafka-console-producer.sh --topic snc.<instance name>.topic1  --producer.config  config/bootcamp.properties  --bootstrap-server <instance name>.service-now.com:4000,<instance name>.service-now.com:4001,<instance name>.service-now.com:4002,<instance name>.service-now.com:4003

      Ersetzen Sie unbedingt\<instance name\> mit dem Namen Ihrer Instanz.  
      Dieser Befehl fordert Sie zur Eingabe von Nachrichten auf. Fügen Sie einige Beispielnachrichten hinzu. In diesem Beispiel werden die folgenden Nachrichten verwendet.
      * Testnachricht1
      * Testnachricht2
      * Testnachricht3
      {#use-kafka-trigger-script-consumer__ul_arc_54m_2yb}Sie sollten die Nachrichten in etwa einer Minute erhalten.
   2. Navigieren Sie zurück zum Flow, und wählen Sie Ausführungenaus.  
   3. Öffnen Sie die Flow-Ausführung.  
   4. Um die Statistiken für dieses Abonnement anzuzeigen, navigieren Sie zu AlleIntegrations-HubStream ConnectAbonnements, öffnen Sie das Abonnement, und wechseln Sie zur Statistikansicht.  
   {#use-kafka-trigger-script-consumer__substeps_nrq_gkq_yxb}
4. Erstellen Sie einen Skript-Verbraucher, um Nachrichten aus dem Thema zu verarbeiten.
   1. Navigieren zu IntegrationHubVerbraucherSkript-Verbraucher.
   2. Wählen Sie Neu.
   3. Geben Sie im Feld Name einen Namen für Ihren Skriptverbraucher ein.  
      In diesem Beispiel wird <kbd class="ph userinput">Topic1 Consumer</kbd>verwendet.
   4. Legen Sie das Skript so fest, dass die Nachricht protokolliert wird, indem Sie im Skriptfeld die folgende Logik hinzufügen.  

          for (var i = 0; i < messages.length; i++) {
                gs.info('Received message ' + JSON.stringify(messages[i].message));
           }

   5. Speichern Sie das Formular.
   6. Wählen Sie im Abschnitt „Zugehörige Links" Neu, um einen Kafka-Stream zum Verwenden der Nachrichten hinzuzufügen.
   7. Legen Sie im Formular „Kafka-Stream" die folgenden Feldwerte fest.  
      * Name des <kbd class="ph userinput">Streams „Thema1“</kbd>
      * Thema zum zuvor erstellten Thema, topic1.
      * Max. Gleichzeitigkeit bis <kbd class="ph userinput">1</kbd>.
      * Verwendung von für alle im Thema gespeicherten Nachrichtenstarten. Mit dieser Option können Sie die bereits in diesem Thema veröffentlichten Nachrichten lesen.
      * Nachrichtenverarbeitungautomatisch optimieren.
      {#use-kafka-trigger-script-consumer__ul_pbp_rqm_2yb}  
   8. Wählen Sie unter Zugehörige Links den Link Aktivieren aus.  
      Sie sollten das aktivierte Abonnement sehen können.
   9. Um die Nachrichten anzuzeigen, navigieren Sie zu AlleSystemprotokolleSystemprotokoll und filtern Sie Nachrichten, die mit Nachricht Empfangen beginnen.  
   10. Sie sollten alle Nachrichten nach 1 Minute sehen.
   {#use-kafka-trigger-script-consumer__substeps_mm5_rkq_yxb}

## Nächste Maßnahme

[Verwenden Sie die ETL- und Transformationszuordnungs-Verbraucher, um Daten zu importieren](https://servicenow-prod.fluidtopics.net/U3AumpPhj~zb_IF11H79gw "Verwenden Sie ETL-Definitionen und Transformationszuordnungen, um Kafka-Ereignisse zu verarbeiten. ETL-Definitionen und Transformationszuordnungen geben die Transformationslogik an, die beim Abrufen von Daten über geplante Importe verwendet werden soll. Sie können dieselben ETL-Definitionen und Transformationszuordnungen verwenden, um die über Kafka empfangenen Ereignisse zu transformieren.").

