Créer un flux Kafka

Rversion finale: Australia

Mis à jour 12 mars 2026

3 minutes de lecture

Définissez un flux de données pour un consommateur d’extraction, de chargement de transformation (ETL), de carte de transformation ou de script. Un flux Kafka définit le flux de données vers votre consommateur.

Avant de commencer

Rôle requis : integration_hub_admin
Les flux Kafka font partie de Connexion au flux ce qui nécessite un Connexion au flux abonnement. Pour plus d'informations, consultez https://www.servicenow.com/now-platform/workflow-data-fabric.html.

Pourquoi et quand exécuter cette tâche

Vous devez créer un flux Kafka pour utiliser un consommateur ETL, Carte de transformation ou Script. Une fois que vous avez configuré un consommateur, et créé et activé un flux, vous pouvez commencer à recevoir des messages de votre environnement Kafka.

Procédure

Ouvrez l’enregistrement de votre consommateur ETL, Carte de transformation ou Script.
Pour trouver un enregistrement de consommateur, accédez à Tous > Centre d'intégration > Consommateurs et sélectionnez Consommateur ETL, Consommateur de carte de transformation ou Consommateur de script.
Localisez la section Flux Kafka et sélectionnez Nouveau.

Renseignez les champs du formulaire.

Tableau 1. Flux Kafka
Champs	Description
Nom	Nom du flux Kafka.
Alias de rubrique	Nom de l’alias de la rubrique pour la rubrique dont les messages sont surveillés.
Concurrence max.	Nombre maximum de processeurs parallèles à utiliser pour consommer des messages et nombre de groupes de partitions à créer. Valeur par défaut : 1
Poids relatif	Pour chaque cycle, durée maximale allouée au consommateur pour le traitement des messages, par rapport aux autres consommateurs. Par exemple, un consommateur dont le poids relatif est deux fois plus élevé que celui d’un autre consommateur dispose de deux fois plus de temps. Les consommateurs qui ont le même poids relatif disposent du même délai. La valeur minimale est 5. La valeur maximale est 2 000. La valeur par défaut est égale à la concurrence max. multipliée par la valeur de la glide.ih.kafka.consumer.max_seconds_per_partition_group propriété. La glide.ih.kafka.consumer.max_seconds_per_partition_group propriété spécifie la durée maximale, en secondes, allouée à chaque groupe de partitions. Sa valeur par défaut est 10. Le système utilise le poids relatif pour calculer le délai d’expiration du groupe de partitions pour l’abonnement. Le délai d’expiration du groupe de partitions spécifie la durée maximale, en millisecondes, allouée à chaque groupe de partitions dans un abonnement spécifique. Ce champ s’affiche uniquement lorsque l’option Avancé est sélectionnée.
Commencer la consommation	Option permettant de spécifier où commencer à consommer les messages de la rubrique. Sélectionnez l'une des options suivantes : Messages reçus après la première activation : consomme uniquement les messages que la rubrique a reçus après l’activation du flux. Tous les messages stockés dans la rubrique : consomme tous les messages de la rubrique, même les messages reçus avant l’activation du flux.
Gestion de message	Option permettant de spécifier le nombre de messages traités par exécution ou de laisser le système décider du nombre de messages. Sélectionnez l'une des options suivantes : Optimisation automatique : le système détermine le nombre de messages à traiter par exécution. Remplacer manuellement : vous spécifiez le nombre de messages à traiter par exécution. Ce champ s’affiche uniquement lorsque l’option Avancé est sélectionnée.
Nombre maximal de messages	Nombre maximal de messages à traiter par exécution. Ce champ s’affiche uniquement lorsque l’option Remplacer manuellement est sélectionnée dans Gestion des messages.
Exécuter en tant que	Option permettant d’exécuter le consommateur avec les informations d’identification d’un utilisateur spécifié.
Consommateur	Nom du consommateur vers lequel diffuser les données. Ce champ est automatiquement défini sur le nom du consommateur à partir duquel vous avez commencé à ajouter le flux.
Actives	Option pour rendre le flux actif.
Avancés	Option permettant d’afficher les champs avancés Poids relatif et Gestion des messages.

Sous Liens connexes, sélectionnez Activer.
Une fois le flux activé, le système crée automatiquement un abonnement Kafka pour le consommateur associé.
Sélectionnez Envoyer.

Résultats

Lorsque vous activez le flux, le consommateur commence à rechercher des messages à traiter dans la rubrique spécifiée. Vous pouvez afficher des informations détaillées sur le consommateur et ses performances en visitant sa page d’abonnement. Pour plus de détails, voir Affichage des abonnements et des statistiques Kafka.