Apache Kafka

Clic droit dans l’arbre ▸ Ajouter ▸ Requête Kafka.

Configuration commune

Champ	Rôle
URL	La liste des courtiers, séparés par des virgules : hote1:9092,hote2:9092 — la chaîne entière est résolue par Handlebars avant d’être découpée
Identifiant client	Le clientId annoncé aux courtiers
Sujet	Le sujet, quel que soit le mode
Mode	produce, consume ou browse

Authentification

Champ	Valeurs
Mécanisme SASL	none, plain, scram-sha-256, scram-sha-512
Utilisateur SASL / Mot de passe SASL	Le mot de passe accepte une valeur de type Secret
TLS	Activable indépendamment — un courtier en TLS sans SASL fonctionne avec le mécanisme none

Mode produce

Clé, valeur, en-têtes d’enregistrement et, facultativement, partition. Sans partition explicite, le partitionneur par défaut de la bibliothèque cliente s’applique. La réponse renvoie les métadonnées de l’enregistrement écrit : sujet, partition, offset.

Mode consume

Champ	Rôle
Groupe	Le groupId du consommateur
Offset de départ	earliest, latest ou specific
Offset spécifique	Une chaîne — les offsets Kafka sont des entiers 64 bits
Partitions	Un filtre côté client : l’affectation aux partitions reste faite par le groupe

Mode browse

Inspecte une partition sans groupe de consommateurs : Restorm y prélève un nombre borné de messages puis se déconnecte. La partition est obligatoire dans ce mode.

C’est le bon outil pour regarder ce qu’il y a dans un sujet sans créer de groupe ni déplacer d’offset.

Dans un scénario

• Production Kafka — action unitaire, renvoie les métadonnées de l’enregistrement ;
• Consommation Kafka — s’abonne via le groupe de consommateurs et émet un événement par message ;
• Fermeture connexion Kafka — arrête la consommation.

Voir Connexions et flux.

Extraits de code

Cinq cibles : JavaScript (kafkajs, en production et en consommation) et kcat (production, consommation, inspection sans groupe).