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

Créez un flux qui traite les événements 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

Nécessite un Connexion au flux pour Apache Kafka abonnement pour Connexion au flux pour Apache Kafka ce déclencheur. Pour plus d'informations, consultez https://www.servicenow.com/products/automation-engine.html.

Ce déclencheur nécessite le module d’extension ServiceNow Integration Hub Flow Trigger - Kafka [com.glide.hub.flow_trigger.kafka].

Procédure

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

   Champ	Description
   Rubrique	Référence à la rubrique dont les messages doivent être surveillés.
   Options avancées
   Démarrer le traitement à partir de	Option permettant de commencer le traitement des messages à partir du début ou de la fin de la file d’attente, organisés par date. Sélectionnez l'une des options suivantes : Le message le plus ancien de la file d’attente : commencez le traitement à partir des messages les plus anciens de la file d’attente. La 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. Remplacement manuel (avancé) : spécifiez le nombre de messages à traiter par exécution.
   Entrez le 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 s’affiche uniquement lorsque l’option Nombre de messages à traiter par exécution est définie sur Remplacement manuel (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. En fonction de 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 maximale 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 Tous > Automatisation des processus > Gestion des flux > Paramètres.
   2. Dans le champ Flux/Flux secondaire/Action , sélectionnez l’icône d’informations ( ) pour le flux, puis sélectionnez Ouvrir l’enregistrement.
   3. Sélectionnez l’icône Actions supplémentaires ( ) et sélectionnez Vue > Kafka.
      Le champ Concurrence maximale apparaît 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 consommer des messages et nombre de groupes de partitions à créer. Valeur par défaut : 1
      Poids relatif	Pour chaque cycle, la 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 temps. La valeur minimale est 5. La valeur maximale est 2 000. La valeur par défaut est égale à la concurrence maximale 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 partition 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 Concepteur de flux.
8. Ajoutez des actions, des flux secondaires et une logique de flux au flux.
9. Pour tester le flux, cliquez sur le bouton Tester .
   Le bouton Test ouvre la boîte de dialogue Flux de test, 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.