Configurer le connecteur consommateur Apache Kafka

  • Rversion finale: Australia
  • Mis à jour 12 mars 2026
  • 5 minutes de lecture

    • Configurez l’instance de connecteur Consumer (Consommateur) Apache Kafka pour créer des événements à partir des messages de diffusion en continu collectés par le Apache Kafka connecteur.

    Avant de commencer

    Assurez-vous que le module d’extension Gestion des événements Connecteurs (sn_em_connector) est installé sur l’instance ServiceNow AI Platform .

    Rôle requis : evt_mgmt_admin

    Procédure

    1. Accédez à la Tous > Gestion des événements > Intégrations > Instances des connecteurs.
    2. Sélectionnez Nouveau.
    3. Remplissez les champs du formulaire.
      Tableau 1. Formulaire Instance de connecteur
      Champ Valeur
      Nom Nom descriptif et unique pour le connecteur de consommateur Kafka.
      Description Description à utiliser par l’instance de collecte d’événements du consommateur Kafka.
      Définition du connecteur Nom de la définition de connecteur requise, qui dans ce cas doit être Consommateur Kafka.
      IP de l'hôte IP de l’hôte.
      Remarque :
      Ce champ doit contenir une valeur pour terminer le processus de création, de sorte que l’espace réservé 1.1.1.1 doit être saisi comme valeur temporaire.
      Heure de la dernière exécution de la collecte d'événements Ce champ est automatiquement défini sur la dernière valeur d’exécution.
      États de la dernière collecte d'événements Ce champ est automatiquement défini sur l’état de la dernière exécution.
      Calendrier de collecte d'événements (secondes) Fréquence, en secondes, à laquelle le système recherche de nouveaux événements à partir du consommateur Kafka. La valeur par défaut est de 60 secondes.
      Dernier message d'erreur Ce champ est automatiquement défini sur le dernier message d’erreur.
    4. Pour PLAINTEXT ou SASL_PLAINTEXT, dans le champ Informations d’identification , créez des informations d’identification d’authentification de base.
      Utilisez le type d’informations d’identification Kafka SSL pour une nouvelle instance de connecteur pull Kafka avec authentification SASL_PLAINTEXT . Passez à l’étape 5.

      Utilisez le type d’informations d’identification Kafka SSL lorsque la valeur du paramètre sasl.enabled.mechanisms ou sasl.mechanism du serveur Kafka n’est pas égale à PLAIN. Passez à l’étape 5.

      1. Sélectionnez l’icône Rechercher en regard du champ Informations d’identification .
      2. Sur l’écran Informations d’identification, sélectionnez Nouveau.
      3. Dans la liste des informations d’identification disponibles, sélectionnez Informations d’identification pour l’authentification de base.
      4. Sur l’écran Authentification de base, fournissez des informations pour l’authentification en texte BRUT, qui ne nécessite pas d’informations d’identification, ou l’authentification SASL_PLAINTEXT, qui nécessite des informations d’identification.
        • Pour l’authentification en texte brut, dans le champ Nom , tapez une valeur et laissez les champs Nom d’utilisateur et Mot de passe vides.
        • Pour SASL_PLAINTEXT authentification, attribuez un nom aux informations d’identification dans le champ Nom, de préférence précédé de SASL. Indiquez le nom d’utilisateur et le mot de passe dans les champs Nom d’utilisateur et Mot de passe .
      5. Sélectionnez Envoyer.
    5. Pour les informations d’identification d’authentification SASL_PLAINTEXT, SSL ou SASL_SSL, dans le champ Informations d’identification , créez des informations d’identification Kafka SSL.
      1. Sélectionnez l’icône Rechercher en regard du champ Informations d’identification .
      2. Sur l’écran Informations d’identification, sélectionnez Nouveau.
      3. Dans la liste des informations d’identification disponibles, sélectionnez Informations d’identification Kafka SSL.
      4. Sur l’écran Authentification Kafka SSL, renseignez les champs d’informations d’identification Kafka SSL.
        Pour les descriptions des champs d’informations d’identification Kafka SSL, reportez-vous à la section .
        Remarque :
        Si vous videz le champ Désactiver la vérification du nom d’hôte , dans le champ Propriétés de consommateur Kafka supplémentaires , saisissez la même valeur du ssl.endpoint.identification.algorithm paramètre que celle du paramètre du serveur Kafka. Par exemple : 
        ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1;
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username=<username> password=<password>;
sasl.enabled.mechanisms=PLAIN;ssl.endpoint.identification.algorithm=;
      5. Sélectionnez Envoyer.
    6. Cliquez avec le bouton droit sur l'en-tête du formulaire, puis sélectionnez Enregistrer.
    7. Dans la table présentant les valeurs de l’instance du connecteur, vérifiez les valeurs de l’instance du connecteur renseignées en fonction de votre configuration Kafka et du message (charge utile JSON) que vous avez reçu de la rubrique Kafka.

      Modifiez les valeurs d’instance du connecteur si nécessaire.

      Tableau 2. Table de valeurs de l’instance du connecteur
      Champ Description
      authentication_type

      Le type d’authentification du consommateur Kafka. Les valeurs actuellement prises en charge sont les suivantes :

      • TEXTE BRUT (aucune authentification) (par défaut)

      • SASL_PLAINTEXT (authentification de base : nom d’utilisateur et mot de passe)
      bootstrap_servers

      Serveurs qui établissent la connexion avec la grappe Kafka. Les valeurs de ce champ doivent être sous la forme host1 :port1, host2 :port2, etc. (séparées par des virgules).

      Ce champ est obligatoire.
      consumer_group_name

      Le nom du groupe de consommateurs.

      Si la même rubrique Kafka est utilisée à partir de deux instances différentes, utilisez des noms de groupes de consommateurs différents afin que tous les événements soient capturés pour les deux instances.

      Ce champ est obligatoire.
      time_of_event_field

      Nom du champ dans la charge/le message JSON qui inclut l’heure de l’événement.

      Si un champ de la charge/du message JSON inclut l’heure de l’événement, cette valeur doit être la valeur de ce paramètre.

      Si aucune valeur de champ d’heure n’est fournie, l’heure de réception de l’événement dans l’instance ServiceNow est définie sur time_of_event.

      Le champ time_of_event doit être un champ de premier niveau dans la charge/le message utile JSON. Les noms de champs imbriqués ne sont pas autorisés.
      fuseau horaire

      Fuseau horaire du champ time_of_event dans la charge/le message JSON.

      La valeur de fuseau horaire n’est pas utilisée lorsque le champ time_of_event est vide.

      Par exemple, si le time_of_event de la charge/du message utile se trouve dans le fuseau horaire IST, la valeur sera GMT+0530.

      Par défaut : GMT.
      date_format

      Le format date_time du champ time_of_event dans la charge/le message JSON.

      Si aucune valeur de champ d’heure n’est fournie, l’heure à laquelle l’événement a été reçu dans l’instance en heure GMT est utilisée. La valeur date_time n’est pas utilisée lorsque le champ time_of_event est vide.

      Par défaut : aaaa-MM-jj HH :mm :sss.
      déboguer Affiche les messages de débogage. Valeur par défaut : faux. Spécifiez vrai pour consulter les messages de débogage.
      logPayloadForDebug Affiche les messages de débogage liés à la charge utile. Valeur par défaut : faux. Spécifiez vrai pour afficher les messages de débogage liés à la charge utile.
      sujet

      Rubrique Kafka à partir de laquelle les messages sont extraits.

      Ce champ est obligatoire.
    8. Dans la section Serveurs MID pour les connecteurs , spécifiez un Serveur MID qui est actif et valide.
      Remarque :
      Vous pouvez en configurer plusieurs Serveurs MID. Si le premier serveur est en panne, le suivant Serveur MID est utilisé. Si elle Serveur MID n’est pas disponible, le suivant est sélectionné, et ainsi de suite. Serveurs MID sont triés en fonction de l’ordre dans lequel leurs détails ont été entrés dans la section Serveurs MID pour les connecteurs .

      Si vous ne spécifiez pas de Serveur MID, un disponible Serveur MID avec une plage d’adresses IP correspondante est utilisé.

    9. Cliquez avec le bouton droit sur l'en-tête du formulaire, puis sélectionnez Enregistrer.
    10. Testez la connexion entre le Serveur MID et le connecteur Kafka Consumer (Consommateur Kafka).
      1. Sélectionnez Tester le connecteur.
      2. Si la connexion de test échoue, vérifiez si les informations d’identification sont valides et si le réseau est connecté Serveur MID au courtier Kafka.
        Remarque :
        La validation du nom de la rubrique Kafka se produit uniquement lors de la validation du connecteur de test .
    11. Après un test réussi, activez l’instance de connecteur en sélectionnant la case à cocher Actif .
    12. Sélectionnez le bouton Update (Mettre à jour ).

    Que faire ensuite

    Une fois le connecteur créé, vous devez mapper les champs. Pour plus d'informations, consultez Mapper les attributs de charge utile du message Kafka aux champs d'alerte.