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-Ereignissammlung 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-Verbraucher sucht. Der Standardwert ist 60 Sekunden. Letzte Fehlermeldung Dieses Feld wird automatisch auf die letzte Fehlermeldung festgelegt. -
Für NUR-TEXT oder SASL_PLAINTEXT in Anmeldeinformationen Feld, Anmeldeinformationen für Standardauthentifizierung erstellen.
Verwenden Sie Kafka-SSL-Anmeldeinformationen Geben Sie für eine neue Kafka Pull Connector-Instanz mit ein SASL_PLAINTEXT Authentifizierung. Wechseln Sie zu Schritt 5.
Verwenden Sie Kafka-SSL-Anmeldeinformationen Geben Sie ein, wenn der Kafka-Server ist sasl.enabled.Mechanismen Oder sasl.Mechanismus Parameterwert ist nicht gleich EINFACH . Wechseln Sie zu Schritt 5.
-
Wählen Sie das Suchsymbol aus
Neben Anmeldeinformationen Feld.
- Wählen Sie auf dem Bildschirm Anmeldeinformationen die Option aus Neu .
- Wählen Sie aus der Liste der verfügbaren Anmeldeinformationen aus Anmeldeinformationen Für Standardauthentifizierung .
-
Geben Sie auf dem Bildschirm „Standardauthentifizierung“ 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 vorangestellt 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 in Anmeldeinformationen Feld, erstellen Sie eine Kafka-SSL-Anmeldeinformation.
-
Wählen Sie das Suchsymbol aus
Neben Anmeldeinformationen Feld.
- Wählen Sie auf dem Bildschirm Anmeldeinformationen die Option aus Neu .
- Wählen Sie aus der Liste der verfügbaren Anmeldeinformationen aus Kafka-SSL-Anmeldeinformationen .
-
Füllen Sie auf dem 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 Verifizierung des Hostnamens Und dann im Feld Zusätzliche Kafka-Verbrauchereigenschaften Geben Sie den Wert von 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_Server 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 Der Name der Verbrauchergruppe.
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 „time_of_event“ in der Nutzlast/Nachricht in der ist-Zeitzone befindet, wäre der Wert „GMT+0530“.
Standard: GMT.
Datum_Format Das Format date_time des Felds time_of_event in der JSON-Nutzlast/-Nachricht.
Wenn kein Zeitfeldwert angegeben ist, wird die Zeit, zu der das Ereignis in der Instanz empfangen wurde, in GMT-Zeit verwendet. Der Wert „date_time“ wird nicht verwendet, wenn das Feld „time_of_event“ leer ist.
Standard: jjjj-MM-tt HH:mm:sss.
debuggen Zeigt Debug-Nachrichten an. Standardwert : Falsch. Geben Sie „wahr“ an, um Debug-Nachrichten anzuzeigen. logPayloadForDebug Zeigt Nutzlast-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 Abschnitt, geben Sie an MID-Server Das ist aktiv und gültig.
Hinweis:Sie können mehrere konfigurieren MID Servers. Wenn der erste Server ausgefallen ist, der nächste MID-Server Wird verwendet. Wenn ja MID-Server Ist nicht verfügbar, der nächste ist ausgewählt usw. MID Servers Werden nach 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 der Kafka-Verbraucher-Connector.
- Wählen Sie Aus Testen Sie Den Connector .
-
Wenn die Testverbindung fehlschlägt, überprüfen Sie, ob die Anmeldeinformationen gültig sind und ob das Netzwerk über verbunden ist MID-Server An den 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.