Utiliser les messages de test d’une Hermes rubrique à l’aide du client Kafka

  • Rversion finale: Xanadu
  • Mis à jour 1 août 2024
  • 2 minutes de lecture
  • Utilisez les messages de test d’une Hermes rubrique en configurant deux clients consommateur.

    Avant de commencer

    Rôle requis : administrateur

    Pourquoi et quand exécuter cette tâche

    Les étapes suivantes décrivent comment configurer deux clients consommateurs et recevoir des messages de test à partir du Hermes cluster Kafka. Étant donné qu’il Hermes utilise une paire de clusters Kafka, vous devez configurer deux clients consommateurs avec des adresses d’amorce de consommateur distinctes.

    Important :
    Vous devez configurer deux adresses d’amorce de consommateur distinctes, une pour chaque client de consommateur.

    Reportez-vous à ces étapes lorsque vous êtes prêt à utiliser les messages provenant de à des Hermes fins professionnelles ou de production.

    Procédure

    1. Accédez au répertoire de configuration dans lequel vous avez extrait Kafka.
      • Par exemple, sous Unix :
        cd /home/user/Software/kafka/config
      • Par exemple, sous Windows :
        cd C:\Software\kafka\config
    2. Configurez les consommateurs.
      1. Ouvrez le fichier consumer.properties .
      2. Configurez les propriétés SSL suivantes :
        security.protocol=SSL
        
        ssl.truststore.password=<truststore password>
        
        ssl.truststore.location=<path to truststore.p12>
        
        ssl.truststore.type=PKCS12
        
        ssl.keystore.password=<keystore password>
        
        ssl.keystore.location=<path to keystore.p12>
        
        ssl.keystore.type=PKCS12
        
        ssl.key.password=<keystore password>
        Remplacez les variables d’espace réservé suivantes :
        • <mot de passe du magasin de confiance> avec votre mot de passe du magasin de confiance
        • <chemin d’accès à truststore.p12> avec le chemin d’accès à votre fichier de magasin de confiance
        • <mot de passe du keystore> avec votre mot de passe du keystore
        • <chemin d’accès à keystore.p12> avec le chemin d’accès à votre fichier magasin de clés
      3. Enregistrez vos changements en texte brut.
    3. Utilisez un message à l’aide de chaque consommateur.
      1. Exécutez la commande suivante pour le premier client consommateur :
        Unix:
        ./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103
        Windows :
        bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.sn_<app_id>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103
        Remplacez les variables d’espace réservé suivantes :
        • <instance_name> avec votre nom d’instance
        • <namespace> avec l’espace de noms du domaine auquel appartient votre rubrique Kafka (facultatif)
        • <app_id> avec l’ID d’application
        • <topic_name> avec un nom de rubrique de test
        • <consumer_group_id> avec une étiquette de votre choix pour le groupe auquel le consommateur appartient
        Remarque :
        Chaque partie du nom de rubrique est sensible à la casse.
      2. Ouvrez une nouvelle fenêtre de terminal.
      3. Accédez au répertoire Kafka.
      4. Exécutez la commande suivante pour le deuxième client consommateur :
        Unix:
        ./bin/kafka-console-consumer.sh --consumer.config ./config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203
        Windows :
        bin/windows/kafka-console-consumer.bat --consumer.config config/consumer.properties --topic snc.<instance_name>.<namespace>.<topic_name> --group snc.<instance_name>.<consumer_group_id> --from-beginning --bootstrap-server <instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203
        Remplacez les variables d’espace réservé suivantes :
        • <instance_name> avec votre nom d’instance
        • <namespace> avec l’espace de noms du domaine auquel appartient votre rubrique Kafka (facultatif)
        • <topic_name> avec un nom de rubrique de test
        • <consumer_group_id> avec une étiquette de votre choix pour le groupe auquel le consommateur appartient
        Remarque :
        Chaque partie du nom de rubrique est sensible à la casse.

    Résultats

    Les messages de test sont consommés à partir de la Hermes grappe Kafka.