Erstellen Sie Nachrichten- und Kafka-Themenreplikationen in Stream Connect
Richten Sie Nachrichten- und Themenreplikationen ein, um Daten zwischen Ihrer Apache Kafka -Umgebung und ServiceNowzu replizieren.
Vorbereitungen
- Erforderliche Rolle: message_replication_admin
- Diese Funktion ist Teil von Stream Connect für Apache Kafka und erfordert ein -Abonnement. Weitere Informationen finden Sie unter Arbeiten mit Stream Connect für Apache Kafka.
- Vergewissern Sie sich, dass Hermes Messaging-Service und der Instanz-PKI-Zertifikatgenerator funktionieren.
- Check the status of and connection to the Hermes Kafka cluster.
- Überprüfen Sie Key Management Framework Health, um sicherzustellen, dass alle drei Elemente im Abschnitt „Instanz-PKI“ betriebsbereit sind.
- Konfigurieren und starten Sie einen MID-Server. Weitere Informationen finden Sie unter Configuring MID Servers. MID-Server muss über die Firewall auf Hermes -Endpunkte zugreifen können. Arbeiten Sie mit Ihrem Netzwerkadministrator zusammen, um sicherzustellen, dass die folgenden Portbereiche offen sind.
- Ersteller: 4000–4050
- Verbraucher1: 4100–4150
- Verbraucher2: 4200–4250
- Stream Connect-Nachrichtenreplikation verwendet einen Alias für Verbindungen und Anmeldeinformationen, um eine Verbindung zu Ihrem lokalen Kafka herzustellen. Create a Connection & Credential alias mit dem VerbindungstypKafka. Für einen Alias für Verbindungen und Anmeldeinformationen sind eine Kafka-Verbindung und Kafka-SSL-Anmeldeinformationenerforderlich.
- Die Stream Connect-Nachrichtenreplikation erfordert das Plugin ServiceNow Stream Connect Replication – Kafka [com.glide.hub.stream_connect.replication.kafka].
Warum und wann dieser Vorgang ausgeführt wird
Auf dieser Seite erfahren Sie, wie Sie einen Nachrichtenreplikationsdatensatz und einen zugehörigen Kafka-Themenreplikationsdatensatz erstellen.
Ein Nachrichtenreplikationsdatensatz stellt einen einzelnen Kafka-Cluster dar. Wenn Sie beispielsweise zwei Kafka-Cluster haben, erstellen Sie zwei verschiedene Nachrichtenreplikationsdatensätze, einen für jeden Cluster. Ein Nachrichtenreplikationsdatensatz ist der übergeordnete Datensatz für alle Themen, die in oder aus diesem Cluster repliziert werden. Nachrichtenreplikationsdatensätze werden in der Tabelle „Nachrichtenreplikationen“ [sys_sc_message_replication] gespeichert.
Ein Kafka-Themenreplikationsdatensatz gibt die Replikation von einem einzelnen Quellthema zu einem einzelnen Zielthema an. Sie können ein einzelnes Quellthema nicht an mehrere Ziele replizieren. Sie können nur einmal an jedes Ziel replizieren. Kafka-Themenreplikationsdatensätze werden in der Tabelle „Kafka-Themenreplikationen“ [sys_kafka_topic_replication] gespeichert.
Prozedur
Ergebnisse
Nachdem Sie alle Ihre Nachrichten- und Themenreplikationsdatensätze erstellt haben, sollten Nachrichten repliziert werden. Sie können die Felder Status und Fehlermeldung im Nachrichtenreplikationsdatensatz auf einen allgemeinen Status der Funktionsweise der Replikation überprüfen.
Sie können auch die Felder Status und Fehlermeldung in jedem einzelnen Kafka-Themenreplikationsdatensatz auf den Status einer bestimmten Themenreplikation überprüfen.
Jeder Kafka-Themenreplikationsdatensatz verfügt auch über eine zugehörige Liste mit dem Namen Nachrichtenreplikationsstatistiken. Sobald Replikationen ausgeführt werden, werden in dieser Liste Metrikdatensätze angezeigt, die alle 60 Sekunden für jede Themenreplikation erstellt werden. Jeder Metrikdatensatz enthält Informationen zur Themenreplikation, einschließlich Nachrichtenanzahl, die die Anzahl der in jedem Erfassungsintervall replizierten Nachrichten angibt.
Nächste Maßnahme
Wenn Sie Nachrichten aus Ihrem lokalen Kafka-Server in ServiceNowreplizieren, können Sie einen Skript-, ETL-oder Transformationszuordnungsverbraucher für die Verarbeitung der Nachrichten konfigurieren oder einen Kafka-Nachrichtenauslöser einrichten, um einen Flow zu starten.
Wenn Sie Nachrichten aus ServiceNow in Ihren lokalen Kafka replizieren, können Sie einen Kafka Producer step in Flow Designer verwenden oder die ProducerV2-API verwenden, um Nachrichten im Thema Hermes und in Ihrem lokalen Kafka zu veröffentlichen.