Erstellen Sie einen Flow mit einem Kafka-Nachrichtenauslöser

Erstellen Sie einen Flow, der Ereignisse aus einem Kafka-Stream verarbeitet. Starten Sie den Flow, wenn ein Ereignis im angegebenen Thema verfügbar ist.

Vorbereitungen

Erforderliche Rolle: flow_designer oder admin

Dieser Auslöser erfordert ein -Abonnement Stream Connect. Weitere Informationen finden Sie unter https://www.servicenow.com/products/automation-engine.html.

Dieser Auslöser erfordert das Plugin ServiceNow Stream Connect-Installationsprogramm [com.glide.hub.stream_connect.installer].

Prozedur

1. Navigieren zu Alle > Prozessautomatisierung > Flow Designer.
2. Klicken Neu > Flow.
3. Definieren Sie die Ablaufeigenschaften.
   Weitere Informationen finden Sie unter Erstellen Sie einen Flow in Workflow-Studio.
4. Klicken Sie im Abschnitt Auslöser auf Auslöser hinzufügen, und wählen Sie Anwendung > Kafka-Nachricht.
5. Füllen Sie die Felder im Formular „Kafka-Nachricht“ aus.

   Feld	Beschreibung
   Thema	Verweis auf das Thema zur Überwachung auf Nachrichten.
   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. Informationen zu Schemas finden Sie unter Schema management in Stream Connect.
   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.
   Erweiterte Optionen
   Verarbeitung starten ab	Option, um mit der Verarbeitung von Nachrichten vom Anfang oder Ende der Warteschlange zu beginnen, sortiert nach Datum. Wählen Sie eine der folgenden Antworten aus. Erste Nachricht in der Warteschlange: Verarbeitung von den ältesten Nachrichten in der Warteschlange beginnen. Das Ende der Warteschlange: Verarbeitung von den neuesten Nachrichten in der Warteschlange beginnend.
   Anzahl der pro Ausführung zu verarbeitenden Nachrichten	Option, um die Anzahl der pro Ausführung verarbeiteten Nachrichten anzugeben oder das System über die Anzahl der Nachrichten entscheiden zu lassen. Wählen Sie eine der folgenden Antworten aus. Automatisch optimieren: Das System bestimmt die Anzahl der pro Ausführung zu verarbeitenden Nachrichten. Manuelle Überschreibung (erweitert): Sie geben die Anzahl der pro Ausführung zu verarbeitenden Nachrichten an.
   Nachrichtenanzahl eingeben (ignoriert bei niedrigerem System-generierten Wert)	Anzahl der bei jeder Ausführung zu verarbeitenden Nachrichten. Dieses Feld wird nur angezeigt, wenn Anzahl der pro Ausführung zu verarbeitenden Nachrichten aufManuelle Überschreibung (erweitert)festgelegt ist. Typ: Ganzzahl Standardwert: 100 Mindestwert: 1 Höchstwert: 100.000 Wenn die ausgewählte Anzahl größer als die vom System berechnete Anzahl ist, wird der Flow mit der vom System berechneten Anzahl ausgeführt. Je nach Größe der Nachrichten kann die Anzahl der pro Ausführung verarbeiteten Nachrichten niedriger sein als die angegebene Anzahl.

6. Klicken Sie auf Erledigt.
7. Wahlweise: Legen Sie die Felder Max. Gleichzeitigkeit und Relative Gewichtung fest.
   Das Feld Max. Gleichzeitigkeit bestimmt die Anzahl der zu erstellenden Partitionsgruppen und die Anzahl der zu verwendenden parallelen Prozessoren. Über das Feld Relative Gewichtung können Sie dem Verbraucher im Vergleich zu anderen Verbrauchern mehr Verarbeitungszeit zuweisen.
   1. Navigieren zu Alle > Prozessautomatisierung > Flowverwaltung > Einstellungen.
   2. Wählen Sie im Feld Flow/SubFlow/Aktion das Infosymbol ( ) für den Flow und dann Datensatz öffnenaus.
   3. Wählen Sie das Symbol „Zusätzliche Aktionen“ (Symbol „ “ ) und wählen Sie Ansicht > Kafka.
      Das Feld Max. Gleichzeitigkeit wird auf dem Formular angezeigt.
   4. Um das Feld Relative Gewichtung anzuzeigen, wählen Sie Erweitert.
   5. Legen Sie die Werte für „Maximale Gleichzeitigkeit“ und „Relative Gewichtung“fest.

      Feld	Beschreibung
      Max. Gleichzeitigkeit	Maximale Anzahl paralleler Prozessoren für die Verarbeitung von Nachrichten und Anzahl der zu erstellenden Partitionsgruppen. Standardwert: 1
      Relative Gewichtung	Für jeden Zyklus die maximale Zeit, die dem Verbraucher für die Verarbeitung von Nachrichten im Vergleich zu anderen Verbrauchern zugewiesen wird. Beispiel: Ein Verbraucher mit einer relativen Gewichtung, die doppelt so hoch ist wie die eines anderen Verbrauchers, erhält doppelt so viel Zeit. Verbraucher mit dem gleichen relativen Gewicht erhalten den gleichen Zeitraum. Der Mindestwert ist 5. Der Höchstwert ist 2000. Der Standardwert entspricht der maximalen Gleichzeitigkeit multipliziert mit dem Wert der Eigenschaft glide.ih.kafka.consumer.max_seconds_per_partition_group. Die Eigenschaft glide.ih.kafka.consumer.max_seconds_per_partition_group gibt die maximale Zeit in Sekunden an, die jeder Partitionsgruppe zugewiesen ist. Der Standardwert ist 10. Das System verwendet die relative Gewichtung, um die Zeitüberschreitung der Partitionsgruppe für das Abonnement zu berechnen. Die Zeitüberschreitung für Partitionsgruppen gibt die maximale Zeit in Millisekunden an, die jeder Partitionsgruppe in einem bestimmten Abonnement zugewiesen ist. Dieses Feld wird nur angezeigt, wenn Erweitert ausgewählt ist.

   6. Wählen Sie Aktualisieren.
   7. Navigieren Sie zurück zu Ihrem Flow in Workflow-Studio.
8. Fügen Sie dem Flow Aktionen, Unterabläufe und eine Ablauflogik hinzu.
9. Um den Flow zu testen, klicken Sie auf die Schaltfläche Test (Testen).
   Über die Schaltfläche Testen wird das Dialogfeld „Test-Flow“ geöffnet, in dem Sie eine Nachricht erstellen können, die an den Flow gesendet werden soll. Das System testet den Flow mit dieser neu erstellten Nachricht, nicht mit Nachrichten aus dem Kafka-Thema. Der Flow empfängt erst Nachrichten vom Thema, wenn er aktiviert ist. Weitere Informationen finden Sie unter Abläufe testen.
10. Um den Flow zu aktivieren, klicken Sie auf die Schaltfläche Aktivieren.
    Wenn Sie den Flow aktivieren, beginnt das System mit der Suche nach Nachrichten im Thema. Sie müssen den Flow aktivieren, um Nachrichten zu empfangen. Weitere Informationen finden Sie unter Abläufe aktivieren.

Ergebnisse

Wenn im Kafka-Thema eine Nachricht vorhanden ist, wird der Flow ausgelöst und die Aktionen werden ausgeführt.