Erstellen Sie einen Flow mit einem Kafka-Nachrichtenauslöser

  • Freigeben Version: Washingtondc
  • Aktualisiert 1. Februar 2024
  • 3 Minuten Lesedauer

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

    Vorbereitungen

    Erforderliche Rolle: flow_designer oder admin

    Dieser Auslöser ist Teil von Stream Connect für Apache Kafka, für das ein Stream Connect für Apache Kafka -Abonnement erforderlich ist. Weitere Informationen finden Sie unter https://www.servicenow.com/products/automation-engine.html.

    Dieser Auslöser erfordert das Plugin ServiceNow Integration Hub Flow Trigger – Kafka [com.glide.hub.flow_trigger.kafka].

    Prozedur

    1. Navigieren zu Alle > Prozessautomatisierung > Flow Designer.
    2. Klicken Neu > Flow.
    3. Definieren Sie die Ablaufeigenschaften.
      Weitere Informationen finden Sie unter Ablauf erstellen.
    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, das auf Nachrichten überwacht werden soll.
      Erweiterte Optionen
      Verarbeitung starten aus Option, um mit der Verarbeitung von Nachrichten am Anfang oder Ende der Warteschlange zu beginnen, geordnet nach Datum. Wählen Sie eine der folgenden Antworten aus.
      • Die früheste Nachricht in der Warteschlange: Beginnen Sie mit der Verarbeitung der ältesten Nachrichten in der Warteschlange.
      • Das Ende der Warteschlange: Beginnen Sie mit der Verarbeitung ab den neuesten Nachrichten in der Warteschlange.
      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 pro Ausführung zu verarbeitenden Nachrichten an.
      Geben Sie die Anzahl der Nachrichten ein (wird ignoriert, wenn der vom System generierte Wert niedriger ist). Anzahl der bei jeder Ausführung zu verarbeitenden Nachrichten. Dieses Feld wird nur angezeigt, wenn Anzahl der pro Ausführung zu verarbeitenden Nachrichten aufManuell überschreiben (erweitert)festgelegt ist.
      • 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.

      Abhängig von der Größe der Nachrichten kann die Anzahl der pro Ausführung verarbeiteten Nachrichten niedriger als die angegebene Anzahl sein.
    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. Mit dem 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 ( Infosymbol) für den Flow und dann Datensatz öffnenaus.
      3. Klicken Sie auf das Symbol „Zusätzliche Aktionen“ (Symbol „ Zusätzliche Aktionen“ ) und dann auf Ansicht > Kafka.
        Das Feld Max. Gleichzeitigkeit wird im Formular angezeigt.
      4. Um das Feld Relative Gewichtung anzuzeigen, wählen Sie Erweitert.
      5. Legen Sie die Werte für Max. Gleichzeitigkeit und Relative Gewichtungfest.
        Feld Beschreibung
        Max. Gleichzeitigkeit

        Maximale Anzahl paralleler Prozessoren, die zum Verarbeiten 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 wird. Zum Beispiel erhält ein Verbraucher mit einer relativen Gewichtung, die doppelt so hoch ist wie die eines anderen Verbrauchers, doppelt so viel Zeit. Verbraucher mit der gleichen relativen Gewichtung erhalten die gleiche Zeit.

        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 werden darf. 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 werden kann.

        Dieses Feld wird nur angezeigt, wenn Erweitert ausgewählt ist.
      6. Wählen Sie Aktualisieren.
      7. Navigieren Sie zurück zu Ihrem Flow in Flow Designer.
    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.
      Die Schaltfläche Test ö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 empfängt erst Nachrichten aus dem Thema, wenn der Flow 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 das Kafka-Thema eine Nachricht enthält, wird der Flow ausgelöst und die Aktionen werden ausgeführt.