Stream Connect Kurzanleitung

  • Freigeben Version: Australia
  • Aktualisiert 12. März 2026
  • 14 Minuten Lesedauer

    • Diese Schnellstartanleitung gibt Ihnen einen Überblick darüber, wie Sie die einzelnen sechs Stream Connect-Produzenten und -Verbraucher für den Datenaustausch zwischen einrichten und verwenden ServiceNow Instanz und eine Kafka-Umgebung.

    Stream Connect hat zwei Ersteller, die Daten von senden ServiceNow In eine Kafka-Umgebung.
    • Kafka-Ersteller Schritt ein Workflow-Studio
    • ProducerV2-API
    Stream Connect hat auch vier Verbraucher, die Daten aus einer Kafka-Umgebung abrufen.
    • Kafka-Nachrichtenauslöser in Workflow-Studio
    • ETL-Verbraucher (Transformationsladen) extrahieren
    • Transformationszuordnungsverbraucher
    • Skript-Verbraucher

    Zum Verknüpfen von ServiceNow Instanz in einer Kafka-Umgebung, Stream Connect verwendet Hermes Messaging-Service. Das folgende Diagramm zeigt jeden der Hersteller und Verbraucher und wie sie eine Verbindung zu Ihrer Kafka-Umgebung herstellen, hier als Kundenstandort , Über Hermes.

    Abbildung : 1. Stream Connect-Produzenten und Verbraucher
    Diagramm, das Stream Connect-Produzenten und -Verbraucher zeigt und wie sie über eine Kafka-Umgebung, die als „Kundenstandort“ beschrieben wird, eine Verbindung herstellen Hermes Messaging-Service.

    Weitere Informationen finden Sie unter Stream Connect für Apache Kafka verwenden Und .

    Erste Schritte

    Zur Darstellung der Kundenwebsite verwendet dieser Leitfaden Apache Kafka Befehlszeilen-Tools werden auf Ihrem Computer ausgeführt. Die mit diesem Tool verwendeten Konfigurationsparameter können verwendet werden, um eine beliebige Client-Verbindung zum Gateway „Anwendungsbereitstellung“, Version 2 (ADCv2), mithilfe des Kafka-Protokolls zu konfigurieren.

    Alle angegebenen Befehle werden mit OpenSSL-Version (LibreSSL 2,8.3) und getestet Apache Kafka Binärverteilungsversion kafka_2,13-3,4.0.tgz. Alle Befehle sollten jedoch mit jeder Version in Ihrer lokalen Umgebung funktionieren.

    Schnellstartschritte

    Diese Schnellstartanleitung besteht aus fünf Schritten. Schritte 1 und 2 behandeln das Einrichten und Testen einer Verbindung zu Hermes. Die Schritte 3 bis 5 zeigen Ihnen, wie Sie jeden der Stream Connect-Hersteller und -Verbraucher konfigurieren und verwenden, um Daten zu senden und zu empfangen.

    1. Das ADCv2-Gateway verwendet gegenseitige Authentifizierung, um Anforderungen zu authentifizieren. Der erste Schritt besteht in der Erstellung eines Schlüsselspeichers und eines Truststores, die mit Ihrem bevorzugten Kafka-Client verwendet werden können. Die folgende Seite zeigt, wie Sie die erforderlichen Zertifikate erstellen: Richten Sie eine sichere Verbindung mit ein Hermes Messaging-Service.
    2. Nachdem Sie eine sichere Verbindung zu Hermes eingerichtet haben, überprüfen Sie, ob der Schlüsselspeicher und der Truststore korrekt von generiert wurden Testen der Verbindung zu Hermes über das ADCv2-Gateway .
    3. Jetzt können Sie es Verwenden Sie den Kafka-Nachrichtenauslöser und den Skriptverbraucher, um Nachrichten zu verbrauchen. Der erste Teil dieser Seite zeigt, wie Sie den Kafka-Nachrichtenauslöser in verwenden Workflow-Studio Zum Abrufen von Nachrichten aus Kafka. Der zweite Teil zeigt, wie Sie den Skriptverbraucher zum Abrufen von Nachrichten verwenden.
    4. Und Verwenden Sie ETL und Transformationszuordnungsverbraucher, um Daten zu importieren. 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 umzuwandeln.
      Hinweis:
      Um den ETL-Verbraucher zu verwenden, benötigen Sie einen Robuster Importsatz-Umwandler . Ebenso benötigen Sie zur Verwendung des Verbrauchers der Transformationszuordnung einen Transformationszuordnung .
    5. Endlich können Sie es Verwenden Sie den Kafka-Ersteller-Schritt und die ProducerV2-API, um Nachrichten zu veröffentlichen. Auf dieser Seite wird gezeigt, wie Sie beide Schritte des Kafka-Erstellers in verwenden Workflow-Studio Und die ProducerV2-API zum Verschieben von Nachrichten an Kafka.

    Richten Sie eine sichere Verbindung mit ein Hermes Messaging-Service

    Sichern Sie Ihre Kafka-Themen, indem Sie einen generieren ServiceNow® Von Instanz signiertes Zertifikat.

    Vorbereitungen

    Wird eingerichtet Hermes Messaging-Service Erfordert Koordination mit Ihrem Netzwerkadministrator und Ihrem Kafka-Administrator. Arbeiten Sie mit Ihrem Netzwerkadministrator zusammen, um die erforderlichen Sicherheitszertifikate zu erhalten und die erforderlichen Ports zu öffnen. Arbeiten Sie mit Ihrem Kafka-Administrator zusammen, um sicherzustellen, dass Ihre Kafka-Umgebung korrekt konfiguriert ist und dass Ihre Anwendungen eine Verbindung mit herstellen können Hermes Messaging-Service Mit dem standardmäßigen Kafka-Protokoll.

    Stellen Sie sicher, dass das folgende Setup vorhanden ist:

    • Die Hermes Messaging-Service Ist aktiviert. Weitere Informationen finden Sie unter .
    • Das Plugin „Schlüsselverwaltungs-Framework“ (com.Glide.kmf.global) ist aktiviert.
    • Die Tabelle „Zertifikate [sys_kmf_certificate]“ enthält einen ServiceNow CA-Stammzertifikat der Instanz.
    • Die Instanz ist nicht mit einer anwenderdefinierten URL konfiguriert. Anwenderdefinierte URLs werden mit dem Instanz-PKI-Zertifikatgenerator nicht unterstützt.

    Erforderliche Rolle: hermes_admin, sn_kmf.cryptographic_Manager oder admin

    Details zum Zuweisen von KMF-Rollen finden Sie unter .

    Prozedur

    1. Navigieren zu Alle > Zertifikatgenerator > Instanz-PKI-Zertifikatgeneratoran.
    2. Wahlweise: Steuern Sie den Zugriff auf Themen, indem Sie Zugriffssteuerungslisten (ACLs) auf Namespace- oder Themenebene konfigurieren.
      OptionBeschreibung
      Wenden Sie ACLs auf Namespaces an
      1. Wählen Sie Aus Konfigurieren Sie ACLs .
      2. Wählen Sie im Dialogfeld „Themen-ACLs“ die Option aus Namespaces .
      3. Geben Sie einen Namespace ein, den Sie konfigurieren möchten.
      4. Legen Sie die Berechtigungsstufe fest, indem Sie eine der beiden auswählen Schreibgeschützt Oder Lesen/Schreiben .
      5. Wählen Sie Hinzufügen.
      Wenden Sie ACLs auf definierte Themen an
      1. Wählen Sie Aus Konfigurieren Sie ACLs .
      2. Wählen Sie im Dialogfeld „Themen-ACLs“ die Option aus Definierte Themen .
      3. Geben Sie ein vorhandenes Thema ein, das Sie konfigurieren möchten.
      4. Legen Sie die Berechtigungsstufe fest, indem Sie eine der beiden auswählen Schreibgeschützt Oder Lesen/Schreiben .
      5. Wählen Sie Hinzufügen.
      Dem Bearer des Zertifikats wird Lese- oder Lese-/Schreibzugriff auf die Themen im Namespace oder das von Ihnen ausgewählte vorhandene Thema gewährt.
    3. Richten Sie die Sicherheit für ein Hermes Messaging-Service.
      1. Navigieren Sie zurück zur Seite „Instanz-PKI-Zertifikatgenerator“.
      2. Geben Sie ein Schlüsselspeicher-Passwort in ein Zertifikatpasswort Feld.
      3. Wählen Sie Aus Generieren .
      Das System generiert ein instanzsigniertes Zertifikat in der Tabelle „Zertifikate“ [sys_kmf_certificate], erstellt einen Schlüsselspeicher und erstellt einen Truststore.

      Wenn eingeschränkter Anruferzugriff für den IPKI-Zertifikatgenerator nicht zulässig ist, wird ein bereichsübergreifender Zugriffsfehler angezeigt. Kontakt Kundenservice und Support Für Unterstützung beim Zulassen des eingeschränkten Anruferzugriffs. So beheben Sie dieses Problem: Kundenservice und Support Kann auf Source_scope=76f9d51369115083f4ea77aab1677cc0 in der Tabelle „eingeschränkte Anruferzugriffsberechtigungen“ [sys_Restricted_caller_Access] verweisen.

    4. Speichern Sie eine Kopie des Schlüsselspeichers, indem Sie auswählen Schlüsselspeicher Herunterladen .
    5. Speichern Sie eine Kopie des Truststore, indem Sie auswählen Truststore Herunterladen .
    6. Kopieren Sie die Schlüsselspeicher- und Truststore-Dateien in jeden Ersteller und Verbraucherclient, der eine Verbindung mit herstellt Hermes Messaging-Service.

    Ergebnisse

    Sie können jetzt eine sichere Verbindung mit erstellen Hermes Messaging-Service.

    Hinweis:
    Sie müssen den Schlüsselspeicher verwenden, den Sie mit dem Instanz-PKI-Zertifikatgenerator generiert haben, um eine Verbindung herzustellen Hermes. Anwenderdefinierte generierte Schlüsselspeicher, die nicht gemäß erstellt werden ServiceNow Dokumentation wird nicht unterstützt.

    Testen Sie die Verbindung zu Hermes über das ADCv2-Gateway

    Überprüfen Sie, ob der Schlüsselspeicher und der Truststore korrekt generiert wurden, indem Sie die Verbindung zu Hermes über das ADCv2-Gateway testen.

    Vorbereitungen

    • Erforderliche Rolle: Integration_Hub_admin

    Prozedur

    1. Herunterladen und installieren Apache Kafka.
      1. Laden Sie herunter Apache Kafka Binärdateien.
      2. Entpacken Sie das Kafka-Paket, indem Sie den folgenden Befehl ausführen: 
        tar -zxvf kafka_2.13-3.1.2.tgz
    2. Navigieren Sie zum Kafka-Verzeichnis, indem Sie den folgenden Befehl ausführen: 
      cd kafka_2.13-3.1.2
    3. Konfigurieren Sie einen Ersteller.
      1. Öffnen Sie Config/producer.properties Datei.
      2. Konfigurieren Sie die folgenden SSL-Eigenschaften: 
        security.protocol=SSL

ssl.truststore.password=<truststore password>

ssl.truststore.location=<path to truststore.p12>

ssl.truststore.type=PKCS12

ssl.keystore.password=<keystore password>

ssl.keystore.location=<path to keystore.p12>

ssl.keystore.type=PKCS12

ssl.key.password=<keystore password>
        Ersetzen Sie die folgenden Platzhaltervariablen:
        • <truststore password> Mit Ihrem Truststore-Passwort.
        • <Pfad zu Truststore.p12> Mit dem Pfad zu Ihrer Truststore-Datei.
        • <keystore password> Mit Ihrem Schlüsselspeicher-Passwort.
        • <Pfad zu Keystore.p12> Mit dem Pfad zu Ihrer Schlüsselspeicherdatei.
      Nachdem Sie die Schritte 1 bis 3 ausgeführt haben, sollten Sie heruntergeladen haben Apache Kafka Und hat producer.properties richtig konfiguriert. Alle in den nächsten Schritten angegebenen Befehle sollten innerhalb von ausgeführt werden Apache Kafka Startverzeichnis.
    4. Kopieren Sie die Datei config/producer.properties in config/bootcamp.properties.
      Dieses Beispiel verwendet Bootcamp Als generischer Name.
      cp config/producer.properties config/bootcamp.properties
    5. Verwenden Sie den folgenden Befehl, um die Themen aufzulisten. 
      bin/kafka-topics.sh --list --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
      Ersetzen Sie unbedingt <instance name> Mit dem Namen Ihrer Instanz.
      Wenn Themen in der Instanz vorhanden sind, sollten sie hier aufgelistet werden.

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

    Ruft Nachrichten von Hermes mit dem Kafka-Nachrichtenauslöser in ab Workflow-Studio Und der Skriptverbraucher.

    Vorbereitungen

    • Erforderliche Rolle: Integration_Hub_admin
    • Der erste Teil dieses Abschnitts zeigt, wie Sie den Kafka-Nachrichtenauslöser in verwenden Workflow-Studio Zum Verbrauchen von Nachrichten. Weitere Informationen zum Auslöser finden Sie unter .
    • Der zweite Teil dieses Abschnitts zeigt, wie Sie den Skriptverbraucher zum Verbrauchen von Nachrichten verwenden. Weitere Informationen finden Sie unter Konfigurieren Sie einen Skriptverbraucher.

    Prozedur

    1. Erstellen Sie ein Thema, um Nachrichten zu verbrauchen.
      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 Alle > IntegrationHub > Stream Connect > Themenan.
        Hinweis:
        Das Erstellen eines Themas dauert etwa 10 Minuten.
    2. Erstellen Sie einen Flow-Auslöser, um Nachrichten aus dem Thema zu verarbeiten.
      1. Navigieren zu Alle > Prozessautomatisierung > Flow Designeran.
      2. Auswählen Neu erstellen > Flussan.
      3. Geben Sie im Formular „Flow-Eigenschaften“ einen Namen für Ihren Flow ein, und geben Sie dann ein Übermitteln .
        In diesem Beispiel wird der Name verwendet Topic1-Verbraucher .
      4. Wählen Sie im Abschnitt Auslöser die Option aus Fügen Sie einen Auslöser hinzu , Und wählen Sie dann aus Kafka-Nachricht Als Auslösertyp.
        Kafka-Nachricht ist der Auslösertyp für den Flow.
      5. Wählen Sie das Thema Themen1 aus.
        Wählen Sie topic1 für das Themenfeld 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ügen > Flow-Logik > Für Jedenan.
      7. Ziehen Sie Nachrichten Datenpille zu Elemente Feld, und wählen Sie dann aus Fertig .
      8. Navigieren Sie im Abschnitt „Aktionen“ des Flows zu Aktion, Flow-Logik oder Subflow hinzufügen > Aktion > ServiceNow Core > Protokollan.
      9. Ziehen Sie Nutzlast Datenpille zu Nachricht Feld, und wählen Sie dann aus Fertig .
        Topic1 Verbraucher-Flow-Auslöser.
      10. Speichern Der 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.
        Erstellen eines neuen Einstellungsdatensatzes, um die Berichterstellung für den Flow zu aktivieren.
      13. Navigieren Sie zurück zu Ihrem Flow, und wählen Sie aus Aktivieren .
      14. Navigieren Sie zu , um Ihr Themenabonnement anzuzeigen Alle > IntegrationHub > Stream Connect > Abonnementsan.
        Das Abonnement für das Thema „topic1“.
    3. Veröffentlichen Sie Nachrichten mit dem Kafka-Befehlszeilentool im Thema.
      1. Führen Sie den folgenden Befehl aus, um Nachrichten im 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
        • Testnachrichten2
        • Testnachricht3
        Sie sollten die Nachrichten in etwa einer Minute erhalten.
      2. Navigieren Sie zurück zum Flow, und wählen Sie aus Ausführungen .
        Wählen Sie Ausführungen aus, um zur Flow-Ausführungsansicht zu navigieren.
      3. Öffnen Sie die Flow-Ausführung.
        Ausführungsdetails für den Flow.
      4. Navigieren Sie zu , um die Statistiken für dieses Abonnement anzuzeigen Alle > IntegrationHub > Stream Connect > Abonnements, Öffnen Sie das Abonnement, und wechseln Sie zur Statistikansicht.
        Die Kafka-Statistiken für das Abonnement.
    4. Erstellen Sie einen Skriptverbraucher, um Nachrichten aus dem Thema zu verbrauchen.
      1. Navigieren zu IntegrationHub > Verbraucher > Skript-Verbraucheran.
      2. Wählen Sie Neu.
      3. In Name Geben Sie einen Namen für Ihren Skriptverbraucher ein.
        Dieses Beispiel verwendet Topic1-Verbraucher .
      4. Legen Sie das Skript fest, um die Nachricht zu protokollieren, indem Sie die folgende Logik im Skriptfeld hinzufügen. 
        for (var i = 0; i < messages.length; i++) {
      gs.info('Received message ' + JSON.stringify(messages[i].message));
 }
        Kafka-Skript-Verbraucher, der das Skript im Feld „Ereignisverbraucher“ anzeigt.
      5. Speichern Sie das Formular.
      6. Wählen Sie im Abschnitt zugehörige Links die Option aus Neu Zum Hinzufügen eines Kafka-Streams zum Verbrauchen der Nachrichten.
      7. Legen Sie im Kafka-Stream-Formular die folgenden Feldwerte fest.
        • Name Bis Themen1-Stream .
        • Thema Zu dem zuvor erstellten Thema, topic1.
        • Max. Gleichzeitigkeit Bis 1 .
        • Mit Dem Verbrauch Beginnen Bis Alle im Thema gespeicherten Nachrichten . Mit dieser Option können Sie die bereits in diesem Thema veröffentlichten Nachrichten lesen.
        • Nachrichtenverarbeitung Bis Automatisch optimieren .
        Der Kafka-Stream-Datensatz.
      8. Wählen Sie aus Aktivieren Link unter zugehörigen Links.
        Sie sollten das aktivierte Abonnement sehen können.
      9. Navigieren Sie zu , um die Nachrichten anzuzeigen Alle > Systemprotokolle > Systemprotokoll Und filtern Sie Nachrichten, die mit der empfangenen Nachricht beginnen.
        Liste der empfangenen Nachrichten.
      10. Sie sollten alle Nachrichten nach 1 Minute sehen.

    Verwenden Sie ETL und Transformationszuordnungsverbraucher, um Daten zu importieren

    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 umzuwandeln.

    Vorbereitungen

    • Erforderliche Rolle: Integration_Hub_admin
    • Der erste Teil dieses Abschnitts zeigt, wie Sie den ETL-Verbraucher zum Verbrauchen von Nachrichten verwenden. Um den ETL-Verbraucher zu verwenden, benötigen Sie einen Robuster Importsatz-Umwandler .
    • Der zweite Teil dieses Abschnitts zeigt, wie Sie einen Transformationszuordnungs-Verbraucher verwenden, um Nachrichten zu verbrauchen. Um den Verbraucher der Transformationszuordnung zu verwenden, benötigen Sie einen Transformationszuordnung .

    Prozedur

    1. Erstellen Sie ein Thema, um ETL zu nutzen und Verbrauchernachrichten zu transformieren.
      1. Verwenden Sie den folgenden Befehl, um ein Thema in Hermes zu erstellen.
        In diesem Beispiel lautet der Themenname topic2. 
        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>.topic2
        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 Alle > IntegrationHub > Stream Connect > Themenan.
        Hinweis:
        Das Erstellen eines Themas dauert etwa 10 Minuten.
    2. Erstellen Sie einen ETL-Verbraucher, um Daten aus dem Thema zu verbrauchen.
      1. Navigieren zu Alle > IntegrationHub > Verbraucher > ETL-Verbraucheran.
      2. Wählen Sie Neu.
      3. Geben Sie im Formular „Kafka-Verbraucher“ einen Namen in ein Name Feld.
        In diesem Beispiel wird der Name Mitgliedsimport verwendet.
      4. Für Robuster Importsatz-Umwandler Wählen Sie einen vorhandenen robusten Importsatz-Umwandler aus.
        Wählen Sie für den robusten Importsatz-Umwandler einen aus, der die Option zum Speichern von Daten in einer einzelnen Spalte nicht verwendet. Um die Nachrichten anzuzeigen, stellen Sie sicher, dass der robuste Importsatz-Umwandler über verfügt Ausführlich Option aktiviert.
      5. Deaktivieren Sie Daten in einer Spalte Option.
        Diese Option sollte nur für Importsatztabellen mit Daten in einer einzelnen Spalte ausgewählt werden.
      6. Legen Sie fest Spaltenzuordnung Bis Bezeichnung .

        Dies bedeutet, dass die JSON-Schlüssel der Eingabenachricht den Spaltenbezeichnungen der Importsatztabelle zugeordnet sind.

        Das Kafka-ETL-Verbraucherformular.
      7. Speichern Sie das Formular.
      8. Erstellen Sie einen Kafka-Stream Für den Verbraucher.
      9. Legen Sie im Kafka-Stream-Formular die folgenden Feldwerte fest.
        • Name Bis Themen2-Stream .
        • Thema Zu dem zuvor erstellten Thema, topic2.
        • Max. Gleichzeitigkeit Bis 1 .
        • Mit Dem Verbrauch Beginnen Bis Nachrichten, die nach der ersten Aktivierung empfangen wurden .
        • Nachrichtenverarbeitung Bis Automatisch optimieren .
      10. Wählen Sie aus Aktivieren Link unter zugehörigen Links.

        Sie sollten das aktivierte Abonnement sehen können.

        Beispiel für Kafka-Stream-Formular für Topic2.
    3. Veröffentlichen Sie Nachrichten in Themen2.
      1. Führen Sie den folgenden Befehl aus, um Nachrichten in Themen2 zu veröffentlichen. 
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --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.

      2. Senden Sie die folgende JSON-Nachricht. 
        {"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
        Sie können diese Nachricht mit beliebigen Werten senden, aber der JSON-Nachrichtenschlüssel muss mit den Tabellenbezeichnungen des Importsatzes übereinstimmen.
      3. Navigieren Sie zurück zu dem von Ihnen erstellten ETL-Verbraucher.

        Nach etwa einer Minute sollten die Daten über den Importsatz importiert worden sein.

        Das Formular „Kafka-Verbraucher“ mit ausgefüllter Registerkarte „Importsätze“.
      4. Um detaillierte Informationen zum Importsatz anzuzeigen, wählen Sie die Importsatznummer aus.
        Detaillierte Ansicht des Importsatzes.
      5. Um detaillierte Informationen zu einer Importsatzzeile anzuzeigen, wählen Sie die Zeilennummer des Importsatzes aus.
        Detaillierte Ansicht der Importsatzzeile
    4. Erstellen Sie einen Transformationszuordnungsverbraucher, um Daten zu verbrauchen.
      1. Navigieren zu Alle > IntegrationHub > Verbraucher > Verbraucher der Transformationszuordnungan.
      2. Wählen Sie Neu.
      3. Geben Sie im Formular „Verbraucher umwandeln – Zuordnung umwandeln“ einen Namen in ein Name Feld.
      4. Für Transformationszuordnung Wählen Sie eine vorhandene Transformationszuordnung aus.
        Das Formular „Verbraucher der Transformationszuordnung“.
      5. Speichern Sie das Formular.
      6. Erstellen Sie einen Kafka-Stream Für den Verbraucher.
      7. Legen Sie im Kafka-Stream-Formular die folgenden Feldwerte fest.
        • Name Bis Transformationszuordnungsstrom .
        • Thema Zu dem zuvor erstellten Thema, topic2.
        • Max. Gleichzeitigkeit Bis 1 .
        • Mit Dem Verbrauch Beginnen Bis Nachrichten, die nach der ersten Aktivierung empfangen wurden .
        • Nachrichtenverarbeitung Bis Automatisch optimieren .
      8. Wählen Sie aus Aktivieren Link unter zugehörigen Links.

        Sie sollten das aktivierte Abonnement sehen können.

        Kafka-Stream-Formular für den Transformationszuordnungs-Verbraucher mit Abonnementinformationen.
    5. Veröffentlichen Sie Nachrichten in Themen2.
      1. Führen Sie den folgenden Befehl aus, um Nachrichten in Themen2 zu veröffentlichen. 
        bin/kafka-console-producer.sh --topic snc.<instance name>.topic2  --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.

      2. Senden Sie die folgende JSON-Nachricht. 
        {"city":"San Diego","name":"Jhon","id":"SN001","state":"California"}
        Sie können diese Nachricht mit beliebigen Werten senden, aber der JSON-Nachrichtenschlüssel muss mit den Tabellenbezeichnungen des Importsatzes übereinstimmen.
      3. Wechseln Sie zu dem von Ihnen erstellten Verbraucher der Transformationszuordnung.
        Nach etwa einer Minute sollten die Daten über den Importsatz importiert worden sein.
      4. Um detaillierte Informationen zum Importsatz anzuzeigen, wählen Sie die Importsatznummer wie oben in Schritt 3d aus.

    Verwenden Sie den Kafka-Ersteller-Schritt und die ProducerV2-API, um Nachrichten zu veröffentlichen

    Daten von übertragen ServiceNow An Hermes, damit die Kafka-Verbraucher sie lesen können.

    Vorbereitungen

    • Erforderliche Rolle: Integration_Hub_admin
    • Der erste Teil dieses Abschnitts zeigt, wie Sie den Schritt „Kafka-Ersteller“ in verwenden Workflow-Studio Zum Veröffentlichen von Nachrichten in Hermes. Weitere Informationen zum Schritt finden Sie unter .
    • Der zweite Teil dieses Abschnitts zeigt, wie Sie die ProducerV2-API zum Veröffentlichen von Nachrichten verwenden. Weitere Informationen finden Sie unter ProducerV2-API .
    • Um alle Nachrichten zu empfangen, müssen Sie zwei Verbraucher für verschiedene Rechenzentren ausführen. Details siehe .

    Prozedur

    1. Starten Sie zwei Verbraucher, um Nachrichten zu erhalten.
      1. Führen Sie die folgenden Befehle über die Befehlszeile aus, um die Nachrichten zu empfangen. 
        bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4100,<instance name>.service-now.com:4101,<instance name>.service-now.com:4102,<instance name>.service-now.com:4103
        bin/kafka-console-consumer.sh --consumer.config config/bootcamp.properties --topic snc.<instance name>.topic1 --group snc.<instance name>.consumer_group1 --from-beginning --bootstrap-server <instance name>.service-now.com:4200, <instance name>.service-now.com:4201, <instance name>.service-now.com:4202, <instance name>.service-now.com:4203
        Ersetzen Sie unbedingt <instance name> Mit dem Namen Ihrer Instanz.
    2. Veröffentlichen Sie Nachrichten aus der Instanz mithilfe eines Flow-Schritts.
      1. Navigieren zu Alle > Prozessautomatisierung > Flow Designeran.
      2. Erstellen Sie eine neue Aktion, indem Sie auswählen Neu erstellen > Aktionan.
      3. Geben Sie Ihrer Aktion im Formular „Aktionseigenschaften“ einen Namen, und wählen Sie dann aus Übermitteln .
        In diesem Beispiel wird der Name Nachrichtenherausgeber verwendet.
      4. Fügen Sie ein hinzu Kafka-Hersteller Schritt zur Aktion.

        Um einen Aktionsschritt hinzuzufügen, wählen Sie das Pluszeichen zwischen aus Eingaben Und Fehlerauswertung In der Aktionsstruktur.

        Fügen Sie der Aktion den Kafka-Ersteller-Schritt hinzu.
      5. Legen Sie im Schritt fest Thema Feld bis Themen1 .
      6. In Nachricht Geben Sie eine Nachricht ein.

        Sie müssen keine anderen Felder ändern.

        Füllen Sie die Felder für den Kafka-Erstellerschritt aus.
      7. Wählen Sie Aus Speichern Zum Speichern der Aktion.
      8. Wählen Sie aus Testen Schaltfläche zum Testen der Aktion.
        Durch das Testen der Aktion wird die Nachricht im Thema veröffentlicht.
      9. Um die Nachricht anzuzeigen, wechseln Sie zu den in Schritt 1 erstellten Befehlszeilenkonsolen.
        Die Nachricht muss in einem der Terminals vorhanden sein.
    3. Veröffentlichen Sie Nachrichten aus der Instanz mithilfe eines Skripts.
      1. Führen Sie das folgende Skript mithilfe des Skripthintergrunds aus, um Nachrichten für dieses Thema aus der Instanz zu veröffentlichen. 
        var producer = new sn_ih_kafka.ProducerV2();
producer.send('<sys id of the topic record>', gs.generateGUID(), 'Test message from ServiceNow', false, null);
        Ersetzen Sie unbedingt <SYS-ID des Themendatensatzes> Mit der sys_ID des Themendatensatzes.
      2. Um die Nachricht anzuzeigen, wechseln Sie zu den in Schritt 1 erstellten Befehlszeilenkonsolen.
        Die Nachricht muss in einem der Terminals vorhanden sein.