Créer un flux avec un déclencheur de message Kafka

Créez un flux qui traite les événements provenant d’un flux Kafka. Démarrez le flux lorsqu’un événement est disponible dans la rubrique spécifiée.

Avant de commencer

Rôle requis : flow_designer ou admin

Ce déclencheur nécessite un Connexion au flux abonnement. Pour plus d'informations, consultez https://www.servicenow.com/now-platform/workflow-data-fabric.html.

Ce déclencheur nécessite le module d’extension Programme d’installation de Connexion au ServiceNow flux [com.glide.hub.stream_connect.installer].

Procédure

1. Accédez à la Tout > Automatisation des processus > Concepteur de flux.
2. Cliquer sur Nouvelle > Flux.
3. Définissez les propriétés du flux.
   Pour plus d'informations, consultez Créer un flux dans Studio de workflow.
4. Dans la section Déclencheur, cliquez sur Ajouter un déclencheur et sélectionnez Demande > Message Kafka.
5. Renseignez les champs du formulaire Message Kafka.

   Champ	Description
   Rubrique	Référence à la rubrique dont les messages doivent être surveillés.
   Format de sérialisation	Le format de sérialisation du message. Sélectionnez l'une des options suivantes : Texte brut : sélectionnez cette option pour tous les messages en texte brut. Il s’agit du format par défaut. Codé : sélectionnez cette option pour les messages au Apache format Avro. La conversion de messages en texte brut au format Avro nécessite un schéma. Sélectionnez le registre de schémas dans le champ Registre de schémas . Pour plus d’informations sur les schémas, reportez-vous à la section Schema management in Stream Connect.
   Registre de schémas	Registre pour le schéma sélectionné. Sélectionnez l'une des options suivantes : Registre de schémas autonome Registre de schémas Confluent Ce champ s’affiche uniquement lorsque le format de sérialisation est défini sur Codé. Pour le registre de schémas Confluent, si l’ID de schéma du message reçu ne se trouve pas dans la table de schémas, le système importe le schéma de manière dynamique, à l’aide de la connexion REST configurée.
   Options avancées
   Démarrer le traitement à partir de	Option permettant de commencer le traitement des messages depuis le début ou la fin de la file d’attente, organisés par date. Sélectionnez l'une des options suivantes : Le message le plus ancien dans la file d’attente : commencez le traitement à partir des messages les plus anciens de la file d’attente. Fin de la file d’attente : commencez le traitement à partir des messages les plus récents de la file d’attente.
   Nombre de messages à traiter par exécution	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 : Optimiser automatiquement : le système détermine le nombre de messages à traiter par exécution. Remplacer manuellement (avancé) : vous spécifiez le nombre de messages à traiter par exécution.
   Entrer nombre de messages (ignoré si la valeur générée par le système est inférieure)	Nombre de messages à traiter à chaque exécution. Ce champ n’apparaît que lorsque le nombre de messages à traiter par exécution est défini sur Remplacer manuellement (avancé). Type : nombre entier Valeur par défaut : 100 Valeur minimale : 1 Valeur maximale : 100 000 Si le nombre sélectionné est supérieur au nombre calculé par le système, le flux s’exécute avec le nombre calculé par le système. Selon la taille des messages, le nombre de messages traités par exécution peut être inférieur au nombre spécifié.

6. Cliquez sur Terminé.
7. Facultatif : Définissez les champs Concurrence maximale et Poids relatif .
   Le champ Concurrence max . détermine le nombre de groupes de partitions à créer et le nombre de processeurs parallèles à utiliser. Le champ Poids relatif vous permet d’allouer plus de temps de traitement au consommateur par rapport aux autres consommateurs.
   1. Accédez à la Tout > Automatisation des processus > Gestion des flux > Paramètres.
   2. Dans le champ Flux/Flux secondaire/Action , sélectionnez l’icône d’informations (icône ) pour le flux, puis sélectionnez Enregistrement ouvert.
   3. Sélectionnez l’icône Actions supplémentaires ( ) et sélectionnez Vue > Kafka.
      Le champ Concurrence max . s’affiche sur le formulaire.
   4. Pour afficher le champ Poids relatif , sélectionnez Avancé.
   5. Définissez les valeurs de concurrence maximale et de poids relatif.

      Champ	Description
      Concurrence max.	Nombre maximal de processeurs parallèles à utiliser pour utiliser 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 à d’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 2000. 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.

   6. Sélectionnez Mettre à jour.
   7. Revenez à votre flux dans Studio de workflow.
8. Ajoutez des actions, des flux secondaires et une logique de flux au flux.
9. Pour tester le flux, cliquez sur le bouton Test .
   Le bouton Test ouvre la boîte de dialogue Tester le flux, dans laquelle vous pouvez créer un message à envoyer au flux. Le système teste le flux avec ce message nouvellement créé, et non avec les messages de la rubrique Kafka. Le flux ne commence pas à recevoir des messages de la rubrique tant qu’il n’est pas activé. Pour plus d'informations, consultez Tester un flux.
10. Pour activer le flux, cliquez sur le bouton Activer .
    Lorsque vous activez le flux, le système commence à rechercher des messages dans la rubrique. Vous devez activer le flux pour recevoir des messages. Pour plus d'informations, consultez Activer un flux.

Résultats

Lorsqu’il y a un message dans la rubrique Kafka, le flux se déclenche et exécute les actions.