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

Rversion finale: Washingtondc

Mis à jour 1 févr. 2024

2 minutes de lecture

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

Avant de commencer

Sécurisez vos rubriques Kafka en générant un certificat et un ServiceNow® magasin de clés signés par une instance. Vous devez fournir les détails du magasin de confiance et du magasin de clés lorsque vous configurez les Hermes consommateurs. Consultez Configurer une connexion sécurisée au Service de messagerie Hermes.
Vous devez créer une rubrique et produire des messages de test dans la grappe Kafka avant de Hermes pouvoir utiliser des messages. Pour en savoir plus, consultez Créer une rubrique de test à Hermes l’aide du client Kafka et Produire des messages de test pour une Hermes rubrique à l’aide du client Kafka.

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 de la Hermes grappe Kafka. Étant donné qu’il Hermes utilise une paire de clusters Kafka, deux clients consommateurs sont nécessaires. Cela signifie que deux adresses d’amorçage distinctes doivent être utilisées, une pour chaque consommateur.

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

Procédure

Téléchargez et installez Apache Kafka.
1. Télécharger le Apache Kafka Binaires.
2. Décompressez le package Kafka en exécutant la commande suivante :
```
tar -zxvf kafka_2.13-3.1.2.tgz
```
Accédez au répertoire Kafka en exécutant la commande suivante :
```
cd kafka_2.13-3.1.2
```
Configurez les consommateurs.
1. Ouvrez le fichier config/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 de magasin de clés

Utilisez un message à l’aide de chaque consommateur.

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
<namespace> avec l’espace de noms du domaine auquel appartient votre rubrique Kafka (facultatif)
<app_id> avec l’ID de l’application
<topic_name> avec un nom de rubrique de test
<consumer_group_id> avec l’étiquette de votre choix pour le groupe auquel le consommateur appartient

Remarque :

Chaque partie du nom de la rubrique est sensible à la casse.

Ouvrez une nouvelle fenêtre de terminal.

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
<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 l’é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 de la Hermes grappe Kafka.