Produire et consommer des messages à partir d’un client Kafka

Apprenez à produire et à consommer des messages à Hermes partir d’un client Kafka.

Pour commencer à échanger des messages à partir d’un client Kafka, commencez par créer une rubrique dans le Hermes cluster Kafka. Une fois la rubrique créée, vous devez créer un total de trois processus avec lesquels communiquer Hermes.

• Un processus est nécessaire pour produire des messages vers Hermes.
• Deux processus sont nécessaires pour utiliser les messages de Hermes. Deux processus sont nécessaires car Hermes utilise une paire de clusters Kafka à des fins de basculement. Si un cluster tombe en panne, les données sont produites dans l’autre Hermes cluster Kafka.
  Important :

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

Un processus consommateur utilise des ports de la gamme 410x et l’autre utilise des ports de la gamme 420x. Cela signifie que vous devez définir deux clients distincts, un pour chaque plage de ports. Dans chaque configuration client, vous pouvez définir des ID de groupes de consommateurs.

Plages de ports requises

Contactez votre administrateur réseau pour vous assurer que les plages de ports suivantes sont ouvertes avant de commencer l’échange de messages à l’aide de Hermes:

• Producteur : 4000-4050
• Consommateur1 : 4100 à 4150
• Consommateur2 : 4 200 à 4 250

Pour confirmer que les ports sont accessibles via le pare-feu, exécutez la commande suivante :

openssl s_client -connect <instance_name>.service-now.com:<port> -servername <instance_name>.service-now.com

• Changez le domaine service-now.com si votre instance utilise un nom de domaine différent.
• Terminez le test en utilisant les ports de chacune des trois plages de ports. Par exemple : testez 4000-4003, 4100-4103 et 4200-4203.

Si la commande échoue en interne mais réussit à partir d’un client extérieur au réseau, consultez votre administrateur réseau pour obtenir l’accès à travers le pare-feu réseau.

Adresses d’amorce

Utilisez les mappages de port suivants pour connecter les producteurs et les consommateurs aux adresses d’amorce du cluster Kafka. Tous les contrôleurs de livraison d’applications utilisés par Hermes suivent la même convention.

Important :

Les exemples d’adresses d’amorce suivants Hermes utilisent les ports 4000-4003, 4100-4103 et 4200-4203. Toutefois, vous devez ouvrir les plages de ports suivantes pour assurer la connectivité lorsque des clusters supplémentaires sont ajoutés au Service de messagerie Hermes.

• Producteur : 4000-4050
• Consommateur1 : 4100 à 4150
• Consommateur2 : 4 200 à 4 250

Les clients du créateur utilisent des ports compris entre 4 000 et 4 050. Par exemple :

Producers = "<instance_name>.service-now.com:4000,<instance_name>.service-now.com:4001,<instance_name>.service-now.com:4002,<instance_name>.service-now.com:4003"

É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 consommateur.

• Le premier client consommateur utilise des ports compris entre 4100 et 4150. Par exemple :

  Consumer A = "<instance_name>.service-now.com:4100,<instance_name>.service-now.com:4101,<instance_name>.service-now.com:4102,<instance_name>.service-now.com:4103"

• Le deuxième client consommateur utilise des ports allant de 4200 à 4250. Par exemple :

  Consumer B = "<instance_name>.service-now.com:4200,<instance_name>.service-now.com:4201,<instance_name>.service-now.com:4202,<instance_name>.service-now.com:4203"

Lorsque vous configurez les propriétés du producteur et du consommateur pour votre propre client Kafka, utilisez ce modèle de chaîne.

Utilisation de l’interface de ligne de commande (CLI)

Lorsque vous utilisez la commande list pour afficher une liste de rubriques, une liste des rubriques actuelles est renvoyée par l’une ou les deux grappes. Les rubriques peuvent être renvoyées à partir d’un seul cluster, en fonction de la date de la dernière synchronisation. Les rubriques créées à des fins de basculement sont différenciées par un préfixe d’identification de cluster à trois lettres.

Lorsque vous accédez aux grappes Hermes à l’aide de l’interface de ligne de commande, des rubriques internes s’affichent en plus de toutes les rubriques que vous avez créées. Pour plus de détails, voir KB1705399.

Vous ne pouvez pas supprimer une rubrique des deux clusters Kafka à l’aide d’une seule commande dans l’interface de ligne de commande (CLI). Toutefois, vous pouvez supprimer la rubrique des deux clusters en supprimant l’enregistrement de rubrique dans votre instance. Consultez Supprimer une rubrique dans Hermes.