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

  • Rversion finale: Yokohama
  • Mis à jour 30 janv. 2025
  • 2 minutes de lecture

    • Utilisez les messages de test d’une Hermes rubrique en configurant deux clients consommateur.

    Avant de commencer

    Rôle requis : admin

    Pourquoi et quand exécuter cette tâche

    Les étapes suivantes décrivent comment configurer deux clients consommateurs et recevoir des messages de test 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. Cela garantit que les messages sont consommés à partir des deux clusters sans perdre de messages.

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

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

    Procédure

    1. Accédez au répertoire de configuration dans lequel vous avez extrait Kafka.
      • Par exemple, sur Unix :
        cd /home/user/Software/kafka/config
      • Par exemple, sur 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 clés de confiance
        • < Mot de passe du magasin de clés > avec votre mot de passe de magasin de clés
        • <chemin d’accès à keystore.p12> avec le chemin d’accès à votre fichier de magasin de clés
      3. Enregistrez vos changements en texte brut.
    3. Utilisez un message utilisant 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 le nom de votre instance
        • <espace de noms> avec l’espace de noms du domaine auquel votre rubrique Kafka appartient (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 la 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 le nom de votre instance
        • <espace de noms> avec l’espace de noms du domaine auquel votre rubrique Kafka appartient (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 la rubrique est sensible à la casse.

    Résultats

    Les messages de test sont consommés à partir du Hermes cluster Kafka.