Créer des réplications de message et de rubrique Kafka dans Connexion au flux
Configurez des réplications de messages et de rubriques pour répliquer des données entre votre environnement et ServiceNow.Apache Kafka
Avant de commencer
- Rôle requis : message_replication_admin
- Cette fonctionnalité nécessite un abonnement. Pour plus d'informations, consultez Utiliser Connexion au flux for Apache Kafka.
- Vérifiez que le générateur de certificats PKI de l’instance Service de messagerie Hermes fonctionnent.
- .
- Vérifiez que les trois éléments de la section PKI d’instance sont opérationnels.
-
Configurez et démarrez une Serveur MID grappe OU Serveur MID . Pour plus d'informations, consultez Configuring MID Servers et Configure a MID Server cluster.
Vous Serveur MID devez pouvoir accéder Hermes aux points de terminaison via le pare-feu. Contactez votre administrateur réseau pour vous assurer que les plages de ports suivantes sont ouvertes.- Producteur : 4000–4050
- Consommateur1 : 4 100 à 4 150
- Consommateur2 : 4 200 à 4 250
Si vous utilisez un Serveur MID cluster, il doit avoir un type de cluster Load Balance. Le type de cluster de basculement n’est pas pris en charge.
- La réplication de message de connexion au flux utilise un alias de connexion et d’informations d’identification pour se connecter à votre Kafka local. Create a Connection & Credential alias avec un type de connexionKafka. Un alias de connexion et d’informations d’identification nécessite une connexion Kafka et des informations d’identification Kafka.
- La réplication de messages de Connexion au flux nécessite le module d’extension Programme d’installation de Connexion au ServiceNow flux [com.glide.hub.stream_connect.installer].
Pourquoi et quand exécuter cette tâche
Cette page vous montre comment créer un enregistrement de réplication de message et un enregistrement de réplication de rubrique Kafka associé.
Un enregistrement de réplication de message représente une seule grappe Kafka. Par exemple, si vous avez deux clusters Kafka, vous devez créer deux enregistrements de réplication de messages différents, un pour chaque cluster. Un enregistrement de réplication de message est l’enregistrement parent pour toutes les rubriques répliquées vers ou à partir de cette grappe. Les enregistrements de réplication de messages sont stockés dans la table de réplications de messages [sys_sc_message_replication].
Un enregistrement de réplication de rubrique Kafka spécifie la réplication à partir d’une rubrique source unique vers une rubrique de destination unique. Vous ne pouvez pas répliquer une rubrique source unique vers plusieurs destinations. Vous ne pouvez répliquer vers chaque destination qu’une seule fois. Les enregistrements de réplication de rubriques Kafka sont stockés dans la table de réplications de rubriques Kafka [sys_kafka_topic_replication].
Procédure
Résultats
Une fois que vous avez créé tous vos enregistrements de réplication de messages et de rubriques, les messages doivent être répliqués. Vous pouvez vérifier l’onglet États de réplication de messages [sys_sc_message_replication_status] sur le formulaire Réplication de messages pour afficher l’état Serveur MID et les messages d’erreur pour chaque réplication de message.
Vous pouvez également vérifier l’onglet États de réplication de canal [sys_sc_channel_replication_status] sur l’enregistrement de réplication de rubrique Kafka pour afficher les détails de l’état de chaque réplication de rubrique, y compris les valeurs Serveur MID, Message d’erreur et Erreur depuis .
Chaque enregistrement de réplication de rubrique Kafka dispose également d’une liste connexe nommée Statistiques de réplication de message. Une fois les réplications en cours d’exécution, cette liste affiche des enregistrements de mesures, qui sont créés toutes les 60 secondes pour chaque réplication de rubrique. Chaque enregistrement de mesures contient des informations sur la réplication de rubrique, notamment le nombre de messages, qui indique le nombre de messages répliqués dans chaque intervalle de collecte.
Que faire ensuite
Si vous répliquez des messages de votre Kafka local vers ServiceNow, vous pouvez configurer un consommateur de script, d’ETL ou de carte de transformation pour traiter les messages ou configurer un déclencheur de message Kafka pour démarrer un flux.
Si vous répliquez des messages vers ServiceNow votre Kafka local, vous pouvez utiliser un ou Studio de workflow utiliser l’API ProducerV2 pour publier des messages sur la Hermes rubrique et votre Kafka local.