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 einen Stream Connect Abonnement. Weitere Informationen finden Sie unter https://www.servicenow.com/now-platform/workflow-data-fabric.html.

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

Prozedur

1. Navigieren zu Alle > Prozessautomatisierung > Flow Designeran.
2. Klicken Neu > Flowan.
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 Fügen Sie einen Auslöser hinzu Und wählen Sie aus Anwendung > Kafka-Nachrichtan.
5. Füllen Sie die Felder im Formular „Kafka-Nachricht“ aus.

   Feld	Beschreibung
   Thema	Verweis auf das Thema, das auf Nachrichten überwacht werden soll.
   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. 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-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.
   Erweiterte Optionen
   Verarbeitung starten ab	Option, mit der Verarbeitung von Nachrichten vom Anfang oder Ende der Warteschlange zu beginnen, organisiert nach Datum. Wählen Sie eine der folgenden Antworten aus. Die früheste Nachricht in der Warteschlange : Beginnt mit der Verarbeitung von den ältesten Nachrichten in der Warteschlange. Das Ende der Warteschlange : Mit der Verarbeitung der neuesten Nachrichten in der Warteschlange beginnen.
   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. Manuell überschreiben (erweitert) : Sie geben die Anzahl der Nachrichten an, die pro Ausführung verarbeitet werden sollen.
   Anzahl der Nachrichten eingeben (ignoriert, wenn der vom System generierte Wert niedriger ist)	Anzahl der Nachrichten, die pro Ausführung verarbeitet werden sollen. Dieses Feld wird nur angezeigt, wenn Anzahl der pro Ausführung zu verarbeitenden Nachrichten Ist auf festgelegt Manuell überschreiben (erweitert) . Typ: Ganzzahl Standardwert: 100 Mindestwert: 1 Höchstwert: 100.000 Wenn die ausgewählte Zahl größer als die vom System berechnete Zahl ist, wird der Flow mit der vom System berechneten Zahl 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 fest Max. Gleichzeitigkeit Und Relative Gewichtung Felder.
   Die Max. Gleichzeitigkeit Das Feld bestimmt die Anzahl der zu erstellenden Partitionsgruppen und die Anzahl der zu verwendenden parallelen Prozessoren. Die Relative Gewichtung Mit dem Feld können Sie dem Verbraucher im Vergleich zu anderen Verbrauchern mehr Verarbeitungszeit zuweisen.
   1. Navigieren zu Alle > Prozessautomatisierung > Flowverwaltung > Einstellungenan.
   2. In Flow/Subflow/Aktion Wählen Sie das Infosymbol ( ) Für den Flow wählen Sie dann aus Öffnen Sie Den Datensatz .
   3. Wählen Sie das Symbol „zusätzliche Aktionen“ ( ) Und wählen Sie aus Ansicht > Kafkaan.
      Die Max. Gleichzeitigkeit Feld wird im Formular angezeigt.
   4. Um anzuzeigen Relative Gewichtung Feld auswählen Erweitert .
   5. Legen Sie die Werte für fest Max. Gleichzeitigkeit Und Relative Gewichtung .

      Feld	Beschreibung
      Max. Gleichzeitigkeit	Maximale Anzahl paralleler Prozessoren, die zum Verbrauchen von Nachrichten verwendet werden sollen, und die 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 Verhältnis zu anderen Verbrauchern zugewiesen ist. Zum Beispiel erhält ein Verbraucher mit einer relativen Gewichtung, die doppelt so hoch ist wie das eines anderen Verbrauchers, doppelt so viel Zeit. Verbraucher mit derselben relativen Gewichtung erhalten dieselbe Zeit. Der Mindestwert ist 5. Der Höchstwert ist 2000. Der Standardwert ist gleich der maximalen Gleichzeitigkeit multipliziert mit dem Wert von glide.ih.kafka.consumer.max_seconds_per_partition_groupEigenschaft. Die glide.ih.kafka.consumer.max_seconds_per_partition_groupDie Eigenschaft 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 der Partitionsgruppe gibt die maximale Zeit in Millisekunden an, die jeder Partitionsgruppe in einem bestimmten Abonnement zugewiesen ist. Dieses Feld wird nur angezeigt, wenn Erweitert Ist ausgewählt.

   6. Wählen Sie Aktualisieren.
   7. Navigieren Sie in zurück zu Ihrem Flow Workflow-Studio.
8. Fügen Sie dem Flow Aktionen, Subflows und Flow-Logik hinzu.
9. Klicken Sie auf , um den Flow zu testen Testen Schaltfläche.
   Die Testen Schaltfläche öffnet das Dialogfeld „Test-Flow“, 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 beginnt erst, Nachrichten aus dem Thema zu empfangen, wenn der Flow aktiviert ist. Weitere Informationen finden Sie unter Einen Ablauf testen.
10. Klicken Sie auf , um den Flow zu aktivieren Aktivieren Schaltfläche.
    Wenn Sie den Flow aktivieren, sucht das System nach Nachrichten im Thema. Sie müssen den Flow aktivieren, um Nachrichten zu erhalten. Weitere Informationen finden Sie unter Flow aktivieren.

Ergebnisse

Wenn das Kafka-Thema eine Nachricht enthält, wird der Flow die Aktionen ausgelöst und ausgeführt.