For AI agents: the complete documentation index is available at https://docs.ovhcloud.com/fr/llms.txt, the full documentation bundle is available at https://docs.ovhcloud.com/fr/llms-full.txt, and this page is available as Markdown at https://docs.ovhcloud.com/fr/guides/public-cloud/data-analytics/analytics/kafka-connect-cluster-cli.md.

Kafka - Comment se connecter à un cluster Kafka en CLI

Voir en Markdown

Découvrez comment vous connecter à un cluster Kafka via la CLI

Objectif

Apache Kafka est une plateforme open source distribuée de streaming d'événements, conçue pour le traitement de données en temps réel et à grande échelle, avec une scalabilité et une durabilité élevées ainsi qu'une faible latence.

Ce guide explique comment vous connecter à un cluster Kafka via la CLI.

Prérequis

En pratique

Première connexion en CLI

Warning

Vérifiez que l'adresse IP visible depuis votre navigateur fait partie des « Authorised IPs » définies pour ce service Kafka.

Vérifiez également que l'utilisateur dispose des ACL nécessaires pour les topics ciblés.

Télécharger les certificats serveur et utilisateur

Pour vous connecter au service Apache Kafka, l'utilisation de certificats serveur et utilisateur est requise.

Certificat serveur

Le certificat CA (Certificate Authority) du serveur peut être téléchargé depuis l'onglet Dashboard :

Certificat serveur Kafka

Certificat utilisateur et clé d'accès

Le certificat utilisateur et la clé d'accès utilisateur peuvent être téléchargés depuis l'onglet Utilisateurs :

Informations utilisateur

Installer une CLI Apache Kafka

Dans le cadre de l'installation officielle d'Apache Kafka, vous obtiendrez différents scripts qui vous permettront également de vous connecter à Kafka dans un environnement Java 8+ : Apache Kafka Official Quickstart.

Nous vous proposons plutôt d'utiliser un client producteur et consommateur générique et plus léger (ne nécessitant pas de JVM) : Kcat (anciennement kafkacat).

Installer Kcat

Pour l'installation de ce client, veuillez suivre les instructions disponibles sur : Kafkacat Official Github.

Fichier de configuration Kcat

Créons un fichier de configuration pour simplifier les commandes CLI agissant comme producteur et consommateur Kafka :

kafkacat.conf :

bootstrap.servers=kafka-f411d2ae-f411d2ae.database.cloud.ovh.net:20186
enable.ssl.certificate.verification=false
ssl.ca.location=/home/user/kafkacat/ca.pem
security.protocol=ssl
ssl.key.location=/home/user/kafkacat/service.key
ssl.certificate.location=/home/user/kafkacat/service.cert

Dans notre exemple, l'adresse et le port du cluster sont kafka-f411d2ae-f411d2ae.database.cloud.ovh.net:20186 et les certificats CA téléchargés précédemment se trouvent dans le dossier /home/user/kafkacat/.

Modifiez ces valeurs selon votre propre configuration.

Producteur Kafka

Pour ce premier exemple, envoyons la clé "test-message-key" et son contenu "test-message-content" vers le topic "my-topic".

echo test-message-content | kcat -F kafkacat.conf -P -t my-topic -k test-message-key

Remarque : selon le binaire installé, la commande CLI peut être kcat ou kafkacat.

Consommateur Kafka

Les données peuvent être récupérées depuis "my-topic".

kcat -F kafkacat.conf -C -t my-topic -o -1 -e

Remarque : selon le binaire installé, la commande CLI peut être kcat ou kafkacat.

Nous voulons vos retours !

Nous serions ravis de répondre à vos questions et apprécions tout retour que vous pourriez nous faire.

Si vous avez besoin d'une formation ou d'une assistance technique pour la mise en oeuvre de nos solutions, contactez votre commercial ou cliquez sur ce lien pour obtenir un devis et demander une analyse personnalisée de votre projet à nos experts de l’équipe Professional Services.

Vous êtes sur Discord ? Rejoignez notre chaîne via https://discord.gg/ovhcloud et interagissez directement avec l’équipe qui développe notre service Analytics !

Rejoignez notre communauté d'utilisateurs.

Cette page vous a-t-elle aidé ?