Konfigurieren Sie den Verbraucher-Connector Apache Kafka .

  • Freigeben Version: Xanadu
  • Aktualisiert 1. August 2024
  • 4 Minuten Lesedauer

    • Konfigurieren Sie die Instanz des Verbraucher-Connectors Apache Kafka, um Ereignisse aus Streaming-Nachrichten zu erstellen, die vom Connector Apache Kafka erfasst werden.

    Vorbereitungen

    Stellen Sie sicher, dass das Plugin Ereignismanagement „ Connectors (sn_em_connector)“ in der Instanz Now Platform installiert ist.

    Erforderliche Rolle: evt_mgmt_admin

    Prozedur

    1. Navigieren zu Alle > Ereignismanagement > Integrationen > Anschlussinstanzen.
    2. Wählen Sie Neu.
    3. Füllen Sie die Felder des Formulars aus.
      Tabelle : 1. Formular Connector-Instanz
      Feld Wert
      Name Beschreibender und eindeutiger Name für den Kafka-Verbraucher-Connector.
      Beschreibung Beschreibung, die von der Instanz der Kafka-Verbraucher-Ereigniserfassung verwendet werden soll.
      Anschlussdefinition Name der erforderlichen Connector-Definition, in diesem Fall Kafka-Verbraucher.
      Host-IP Die Host-IP.
      Hinweis:
      Dieses Feld muss einen Wert enthalten, um den Erstellungsprozess abzuschließen. Daher muss der Platzhalter 1.1.1.1 als temporärer Wert eingegeben werden.
      Zeit der letzten Ausführung der Event-Erfassung Dieses Feld wird automatisch auf den letzten Laufzeitwert festgelegt.
      Letzter Event-Erfassungsstatus Dieses Feld wird automatisch auf den letzten Laufzeitstatus gesetzt.
      Zeitplan für Event-Erfassung (Sekunden) Die Häufigkeit in Sekunden, mit der das System nach neuen Ereignissen vom Kafka Consumer sucht. Der Standardwert beträgt 60 Sekunden.
      Letzte Fehlermeldung Dieses Feld wird automatisch auf die letzte Fehlermeldung festgelegt.
    4. Erstellen Sie für PLAINTEXT oder SASL_PLAINTEXT im Feld Anmeldeinformationen die Anmeldeinformationen für die Standardauthentifizierung.
      Verwenden Sie den SSL-Anmeldeinformationstyp Kafka für eine neue Kafka-Pull-Connector-Instanz mit SASL_PLAINTEXT- Authentifizierung. Fahren Sie mit Schritt 5 fort.

      Verwenden Sie den SSL-Anmeldeinformationstyp Kafka, wenn der Wert des Parameters „ sasl.enabled.mechanismen“ oder „ sasl.mechanismus “ des Kafka-Servers nicht gleich PLAIN ist. Fahren Sie mit Schritt 5 fort.

      1. Wählen Sie das Suchsymbol Suchsymbol neben dem Feld Anmeldeinformationen.
      2. Wählen Sie im Bildschirm Anmeldeinformationen Neu.
      3. Wählen Sie in der Liste der verfügbaren Anmeldeinformationen Anmeldeinformationen für Standardauthentifizierungaus.
      4. Geben Sie im Bildschirm „Standardauthentifizierung“ Informationen für die PLAINTEXT-Authentifizierung an, für die keine Anmeldeinformationen erforderlich sind, oder für die SASL_PLAINTEXT-Authentifizierung, für die Anmeldeinformationen erforderlich sind.
        • Geben Sie für die PLAINTEXT-Authentifizierung im Feld Name einen beliebigen Wert ein, und lassen Sie die Felder Anwendername und Passwort leer.
        • Geben Sie für die SASL_PLAINTEXT-Authentifizierung im Feld Name einen Namen für die Anmeldeinformationen ein, vorzugsweise mit dem Präfix SASL. Geben Sie den Anwendernamen und das Passwort in den Feldern Anwendername und Passwort an.
      5. Wählen Sie Absenden.
    5. Erstellen Sie für SASL_PLAINTEXT-, SSL- oder SASL_SSL-Authentifizierungsanmeldeinformationen im Feld Anmeldeinformationen Kafka SSL-Anmeldeinformationen.
      1. Wählen Sie das Suchsymbol Suchsymbol neben dem Feld Anmeldeinformationen.
      2. Wählen Sie im Bildschirm Anmeldeinformationen Neu.
      3. Wählen Sie in der Liste der verfügbaren Anmeldeinformationen Kafka SSL-Anmeldeinformationenaus.
      4. Füllen Sie im Bildschirm „Kafka SSL-Authentifizierung“ die Felder für Kafka SSL-Anmeldeinformationen aus.
        Beschreibungen der Felder für SSL-Anmeldeinformationen für Kafka finden Sie unter .
        Hinweis:
        Wenn Sie das Feld Verifizierung des Hostnamens deaktivieren löschen, geben Sie im Feld Zusätzliche Kafka-Verbrauchereigenschaften den Wert des Parameters ssl.endpoint.identification.algorithm ein, der dem Wert des Kafka-Serverparameters entspricht. Beispiel: 
        ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1;
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=<username> password=<password>;
sasl.enabled.mechanisms=PLAIN;ssl.endpoint.identification.algorithm=;
      5. Wählen Sie Absenden.
    6. Rechtsklicken Sie auf die Formularüberschrift und wählen Sie Speichern.
    7. Überprüfen Sie in der Tabelle mit den Connector-Instanzwerten die ausgefüllten Connector-Instanzwerte basierend auf Ihrem Kafka-Setup und der Nachricht (JSON-Nutzlast), die Sie vom Kafka-Thema erhalten haben.

      Ändern Sie bei Bedarf die Werte der Connector-Instanz.

      Tabelle : 2. Wertetabelle für die Connector-Instanz
      Feld Beschreibung
      authentication_type

      Der Kafka-Verbraucher-Authentifizierungstyp. Die derzeit unterstützten Werte sind:

      • PLAINTEXT (keine Authentifizierung) (Standard)

      • SASL_PLAINTEXT (Standardauthentifizierung – Anwendername und Passwort)
      bootstrap_servers

      Die Server, die die Verbindung zum Kafka-Cluster herstellen. Die Werte in diesem Feld müssen das Format „host1:port1“, „host2:port2“ usw. haben (kommagetrennt).

      Dies ist ein Pflichtfeld.
      consumer_group_name

      Verbrauchergruppenname.

      Wenn dasselbe Kafka-Thema von zwei verschiedenen Instanzen verwendet wird, verwenden Sie unterschiedliche Verbrauchergruppennamen, damit alle Ereignisse für beide Instanzen erfasst werden.

      Dies ist ein Pflichtfeld.
      time_of_event_field

      Der Name des Felds in der JSON-Nutzlast/Nachricht, das die Zeit des Ereignisses enthält.

      Wenn ein Feld in der JSON-Nutzlast/Nachricht die Zeit des Ereignisses enthält, sollte dieser Wert der Wert für diesen Parameter sein.

      Wenn kein Zeitfeldwert angegeben ist, wird die Empfangszeit des Ereignisses in der Instanz ServiceNow als „time_of_event“ festgelegt.

      Das Feld „time_of_event“ muss ein Feld der ersten Ebene in der JSON-Nutzlast/Nachricht sein. Verschachtelte Feldnamen sind nicht zulässig.
      timezone

      Die Zeitzone des Felds „time_of_event“ in der JSON-Nutzlast/Nachricht.

      Der Zeitzonenwert wird nicht verwendet, wenn das Feld „time_of_event“ leer ist.

      Wenn sich beispielsweise „time_of_event“ in der Nutzlast/Nachricht in der IST-Zeitzone befindet, lautet der Wert „GMT+0530“.

      Standardwert: GMT.
      date_format

      Das Format „date_time“ des Felds „time_of_event“ in der JSON-Nutzlast/Nachricht

      Wenn kein Zeitfeldwert angegeben wird, wird die Zeit verwendet, zu der das Ereignis in der Instanz in GMT-Zeit empfangen wurde. Der Wert von „date_time“ wird nicht verwendet, wenn das Feld „time_of_event“ leer ist.

      Standardwert: jjjj-MM-tt HH:mm:ss.
      debuggen Zeigt Debug-Nachrichten an. Standardwert: false. Geben Sie true an, um Debug-Nachrichten anzuzeigen.
      logPayloadForDebug Zeigt nutzlastbezogene Debug-Nachrichten an. Standardwert: false. Geben Sie „wahr“ an, um nutzlastbezogene Debug-Nachrichten anzuzeigen.
      Thema

      Das Kafka-Thema, aus dem die Nachrichten abgerufen werden.

      Dies ist ein Pflichtfeld.
    8. Geben Sie im Abschnitt „ MID-Server für Connectors “ einen aktiven und gültigen MID-Server an.
      Hinweis:
      Sie können mehrere MID Servers konfigurieren. Wenn der erste Server ausgefallen ist, wird der nächste MID-Server verwendet. Wenn MID-Server nicht verfügbar ist, wird das nächste ausgewählt usw. MID Servers sind in der Reihenfolge sortiert, in der ihre Daten im Abschnitt „ MID-Server für Connectors “ eingegeben wurden.

      Wenn Sie kein MID-Serverangeben, wird ein verfügbares MID-Server mit einem übereinstimmenden IP-Bereich verwendet.

    9. Rechtsklicken Sie auf die Formularüberschrift und wählen Sie Speichern.
    10. Testen Sie die Verbindung zwischen MID-Server und dem Kafka Consumer-Connector.
      1. Wählen Sie Connector testen.
      2. Wenn die Testverbindung fehlschlägt, überprüfen Sie, ob die Anmeldeinformationen gültig sind und ob das Netzwerk von MID-Server mit dem Kafka-Broker verbunden ist.
        Hinweis:
        Die Validierung des Kafka-Themennamens erfolgt nur bei der Test-Connector- Validierung.
    11. Aktivieren Sie nach einem erfolgreichen Test die Connector-Instanz, indem Sie das Kontrollkästchen Aktiv aktivieren.
    12. Wählen Sie die Schaltfläche Aktualisieren aus.

    Nächste Maßnahme

    Nachdem der Connector erstellt wurde, müssen Sie die Felder zuordnen. Weitere Informationen finden Sie unter Nutzlastattribute der Kafka-Nachricht an Warnungsfelder zuordnen.