Konfigurieren Sie den Apache Kafka Consumer-Connector

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

    • Konfigurieren Sie die Verbraucher-Connector-Instanz Apache Kafka, um Events 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 Consumer-Connector.
      Beschreibung Beschreibung, die von der Instanz der Kafka Consumer-Event-Erfassung verwendet werden soll.
      Anschlussdefinition Name der erforderlichen Connector-Definition, in diesem Fall Kafka Consumer.
      Host-IP 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 gesetzt.
      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 gesetzt.
    4. Erstellen Sie für PLAINTEXT oder SASL_PLAINTEXT im Feld Anmeldeinformationen Anmeldeinformationen für die Standardauthentifizierung.
      Verwenden Sie den Kafka-SSL-Anmeldeinformationstyp für eine neue Kafka-Pull-Connector-Instanz mit SASL_PLAINTEXT- Authentifizierung. Fahren Sie mit Schritt 5 fort.

      Verwenden Sie den Kafka-SSL-Anmeldeinformationstyp, wenn der Wert des Parameters sasl.enabled.mechanismus oder sasl.mechanismus des Kafka-Servers nicht dem Wert PLAIN entspricht. Fahren Sie mit Schritt 5 fort.

      1. Klicken Sie auf das Suchsymbol Suchsymbol neben dem Feld Anmeldeinformationen.
      2. Wählen Sie im Bildschirm „Anmeldeinformationen“ die Option Neuaus.
      3. Wählen Sie in der Liste der verfügbaren Anmeldeinformationen Anmeldeinformationen für Standardauthentifizierungaus.
      4. Geben Sie im Bildschirm „Basic Authentication“ 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 Benutzername und Passwort leer.
        • Geben Sie für die SASL_PLAINTEXT-Authentifizierung einen Namen für die Anmeldeinformationen im Feld Name ein, vorzugsweise mit dem Präfix SASL. Geben Sie den Benutzernamen und das Passwort in die Felder Benutzername und Passwort ein.
      5. Wählen Sie Absenden.
    5. Erstellen Sie für Anmeldeinformationen für die SASL_PLAINTEXT-, SSL- oder SASL_SSL-Authentifizierung im Feld Anmeldeinformationen Kafka-SSL-Anmeldeinformationen.
      1. Klicken Sie auf das Suchsymbol Suchsymbol neben dem Feld Anmeldeinformationen.
      2. Wählen Sie im Bildschirm „Anmeldeinformationen“ die Option Neuaus.
      3. Wählen Sie in der Liste der verfügbaren Anmeldeinformationen Kafka SSL-Anmeldeinformationenaus.
      4. Füllen Sie im Bildschirm „Kafka SSL Authentication“ (Kafka-SSL-Authentifizierung) die Felder für Kafka-SSL-Anmeldeinformationen aus.
        Beschreibungen der Felder für Kafka-SSL-Anmeldeinformationen finden Sie unter .
        Hinweis:
        Wenn Sie das Feld Hostnamenverifizierung deaktivieren löschen, geben Sie im Feld Zusätzliche Kafka-Verbrauchereigenschaften den Wert des Parameters ssl.endpoint.identification.algorithm ein, der mit dem Wert des Kafka-Serverparameters identisch ist. 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 Connector-Instanzwerte.

      Tabelle : 2. Connector-Instanz – Wertetabelle
      Feld Beschreibung
      authentication_type

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

      • PLAINTEXT (keine Authentifizierung) (Standard)

      • SASL_PLAINTEXT (Standardauthentifizierung – Benutzername und Passwort)
      bootstrap_servers

      Die Server, die die Verbindung mit dem Kafka-Cluster herstellen 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 aus zwei verschiedenen Instanzen verwendet wird, verwenden Sie unterschiedliche Verbrauchergruppennamen, damit alle Events 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 Ereignisse 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. Geschachtelte 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.

      Beispiel: Wenn time_of_event in der Nutzlast/Nachricht in der IST-Zeitzone liegt, lautet der Wert GMT+0530.

      Standardwert: GMT.
      date_format

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

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

      Standardwert: jjjj-MM-tt HH:mm:ss.
      debuggen Option zum Anzeigen von Debug-Protokollen. Standardwert: false
      logPayloadForDebug Option zum Anzeigen von JSON-Nutzlast-bezogenen Protokollen. Standardwert: false
      Thema

      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 der nächste ausgewählt usw. MID Servers werden nach der Reihenfolge sortiert, in der ihre Details im Abschnitt „ MID Server für Connectors “ eingegeben wurden.

      Wenn Sie keinen MID-Serverangeben, wird ein verfügbarer 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. Klicken Sie auf die Schaltfläche Aktualisieren.

    Nächste Maßnahme

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