Konfigurieren Sie Apache Kafka Verbraucher-Connector
Konfigurieren Sie Apache Kafka Verbraucher-Connector-Instanz zum Erstellen von Ereignissen aus Streaming-Nachrichten, die von erfasst wurden Apache Kafka Connector.
Vorbereitungen
Stellen Sie sicher, dass Ereignismanagement Plugin „Connectors“ (sn_em_Connector) ist auf installiert ServiceNow AI Platform Instanz.
Erforderliche Rolle: evt_mgmt_admin
Prozedur
- Navigieren zu Alle > Ereignismanagement > Integrationen > Anschlussinstanzenan.
- Wählen Sie Neu.
-
Füllen Sie im Formular die Felder 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. Connector-Definition Name der erforderlichen Connector-Definition, die in diesem Fall Kafka-Verbraucher sein sollte. Host-IP Die Host-IP. Hinweis:Dieses Feld muss einen Wert enthalten, um den Erstellungsprozess abzuschließen, daher sollte der Platzhalter 1.1.1.1 als temporärer Wert eingegeben werden.Zeit der letzten Ausführung der Eventsammlung Dieses Feld wird automatisch auf den letzten Laufzeitwert festgelegt. Status der letzter Eventsammlung Dieses Feld wird automatisch auf den letzten Laufzeitstatus festgelegt. Zeitplan für Eventsammlung (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. -
Für NUR-TEXT oder SASL_PLAINTEXT in Anmeldeinformationen Feld, erstellen Sie Anmeldeinformationen für die Standardauthentifizierung.
Verwenden Sie Kafka-SSL-Anmeldeinformationen Geben Sie eine neue Kafka-Pull-Connector-Instanz mit ein SASL_PLAINTEXT Authentifizierung. Fahren Sie mit Schritt 5 fort.
Verwenden Die Kafka-SSL-Anmeldeinformationen Geben Sie ein, wenn der Kafka-Server ist sasl.enabled.Mechanismen Oder sasl.Mechanismus Parameterwert ist nicht gleich EINFACH . Fahren Sie mit Schritt 5 fort.
-
Wählen Sie das Suchsymbol aus
Neben Anmeldeinformationen Feld.
- Wählen Sie im Bildschirm Anmeldeinformationen die Option aus Neu .
- Wählen Sie in der Liste der verfügbaren Anmeldeinformationen die Option aus Anmeldeinformationen Für Standardauthentifizierung .
-
Geben Sie auf dem Bildschirm „Standardauthentifizierung“ entweder Informationen für die NUR-TEXT-Authentifizierung an, die keine Anmeldeinformationen erfordert, oder für die SASL_PLAINTEXT-Authentifizierung, die Anmeldeinformationen erfordert.
- Für die NUR-TEXT-Authentifizierung in Name Feld einen beliebigen Wert eingeben und belassen Anwendername Und Passwort Felder leer.
- Geben Sie für die SASL_PLAINTEXT-Authentifizierung einen Namen für die Anmeldeinformationen in an Name Feld, vorzugsweise mit vorangestelltem SASL . Geben Sie den Anwendernamen und das Passwort in an Anwendername Und Passwort Felder.
- Wählen Sie Absenden.
-
Wählen Sie das Suchsymbol aus
-
Für SASL_PLAINTEXT-, SSL- oder SASL_SSL-Authentifizierungsanmeldeinformationen im Anmeldeinformationen Feld erstellen Sie eine Kafka-SSL-Anmeldeinformation.
-
Wählen Sie das Suchsymbol aus
Neben Anmeldeinformationen Feld.
- Wählen Sie im Bildschirm Anmeldeinformationen die Option aus Neu .
- Wählen Sie in der Liste der verfügbaren Anmeldeinformationen die Option aus Kafka-SSL-Anmeldeinformationen .
-
Füllen Sie im Bildschirm 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 löschen Deaktivieren Sie die Hostnamenverifizierung Feld, dann in Zusätzliche Kafka-Verbrauchereigenschaften Geben Sie den Wert des ein ssl.endpoint.identification.algorithmParameter ist identisch mit dem Kafka-Server-Parameterwert. Zum 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=; - Wählen Sie Absenden.
-
Wählen Sie das Suchsymbol aus
- Rechtsklicken Sie auf die Formularüberschrift und wählen Sie Speichern.
-
Ü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. Tabelle der Connector-Instanzwerte Feld Beschreibung authentication_type Der Authentifizierungstyp des Kafka-Verbrauchers. Die derzeit unterstützten Werte sind:
NUR-TEXT (keine Authentifizierung) (Standard)
SASL_PLAINTEXT (Standardauthentifizierung – Anwendername und Passwort)
bootstrap_servers Die Server, die die Verbindung zum Kafka-Cluster herstellen. Werte in diesem Feld müssen das Format host1:port1, host2:port2 usw. aufweisen (kommagetrennt).
Dies ist ein Pflichtfeld.
consumer_group_name Verbrauchergruppenname.
Wenn dasselbe Kafka-Thema von zwei verschiedenen Instanzen verbraucht wird, verwenden Sie verschiedene 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, muss dieser Wert der Wert für diesen Parameter sein.
Wenn kein Zeitfeldwert angegeben ist, wird die Empfangszeit des Ereignisses in angegeben ServiceNow Instanz ist 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.
Feld 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 die Zeit_des_Ereignisses in der Nutzlast/Nachricht in der ist-Zeitzone befindet, wäre 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 ist, wird die Zeit verwendet, zu der das Ereignis in der Instanz empfangen wurde, in GMT-Zeit. Der Wert 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: Falsch. Geben Sie true an, um Debug-Nachrichten anzuzeigen. logPayloadForDebug Zeigt Payload-bezogene Debug-Nachrichten an. Standardwert: Falsch. Geben Sie „wahr“ an, um nutzlastbezogene Debug-Nachrichten anzuzeigen. Thema Das Kafka-Thema, aus dem die Nachrichten abgerufen werden.
Dies ist ein Pflichtfeld.
-
In MID-Server für Connectors Geben Sie einen Abschnitt an MID-Server Die aktiv ist und gültig ist.
Hinweis:Sie können mehrere MID Servers konfigurieren. Wenn der erste Server ausgefallen ist, der nächste MID-Server Wird verwendet. Wenn ja MID-Server Ist nicht verfügbar, der nächste wird ausgewählt usw. MID Servers Werden in der Reihenfolge sortiert, in der ihre Details in eingegeben wurden MID-Server für Connectors Abschnitt.
Wenn Sie keinen angeben MID-Server, Ein verfügbar MID-Server Wird verwendet, der einen übereinstimmenden IP-Bereich hat.
- Rechtsklicken Sie auf die Formularüberschrift und wählen Sie Speichern.
-
Testen Sie die Verbindung zwischen MID-Server Und den Kafka-Verbraucher-Connector.
- Wählen Sie Connector testen.
-
Wenn die Testverbindung fehlschlägt, überprüfen Sie, ob die Anmeldeinformationen gültig sind und ob das Netzwerk über verbunden ist MID-Server Zum Kafka-Broker.
Hinweis:Die Validierung des Kafka-Themennamens findet nur in statt Testen Sie Den Connector Validierung.
- Aktivieren Sie nach einem erfolgreichen Test die Connector-Instanz, indem Sie auswählen Aktiv Kontrollkästchen.
- Wählen Sie aus Aktualisieren Schaltfläche.
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.