Cahier de TP
KAFKA
Cahier de travaux pratiques
Rahmeni Raoudha
[Link]@[Link]
1
Cahier de TP
ATELIER 1 : INSTALLATION DE KAFKA &
DEVELOPPEMENT DE PRODUCTEUR ET
CONSOMMATEUR
Avant de commencer regarder une vidéo
1. Nous allons commencer par installer l’environnement d’exécution Java 8 :
[Link]
2. Installer Kafka : [Link]
3. Dézipez le dossier, copiez le contenu du dossier et le coller sous D://
BigDataLocalSetup et le renommez Kafka
4. Allez vers les fichiers de configurations Kafka/config
5. Configurez les fichier [Link] en changeant le nom de la variable
[Link]=D:/BigDataLocalSetup/tmp/kafka-logs
6. Faites attention les Slash doivent être comme suit /
7. Configurez les fichier [Link] en changeant le nom de la variable
dataDir=D:/BigDataLocalSetup/tmp/zookeeper
8. Se déplacer vers le dossier kafka
Nous avons besoin de lancer deux composants :
● Zookeeper, qui est le gestionnaire de cluster de Kafka.
● Un serveur Kafka que l'on nommera broker.
● Créer un topic
● lancer kafka producer
● lancer kafka consumer
9. Ouvrir le terminal (cmd) pour lancer Zookeeper
./bin/windows/[Link] ./config/[Link]
2
Cahier de TP
10. Ouvrir le terminal (cmd) pour lancer le serveur Kafka ou le nom Broker
./bin/windows/[Link] ./config/[Link]
Une fois le serveur lancé, nous pouvons créer un système de producteur / consommateur en
ligne de commande très rapidement.
Dans le dossier <your_folder_path>\bin\windows, on peut trouver les fichiers kafka-console-
[Link] et [Link]
Ces fichiers nous serviront plus tard. Avant, nous avons besoin de créer des topics.
11. Lancez le terminal (cmd) pour créer un topic
./bin/windows/[Link] --create --myFirstTopic --bootstrap-server
localhost:9092
Production et consommation de messages
Pour la production de messages, Il faut lancer un producteur (producer), il faut “ouvrir” le
topic avec cette commande :
12. Lancez la commande
./bin/windows/[Link] --topic myFirstTopic --bootstrap-server
localhost:9092
Une fois cette commande exécutée, la console “attendra” des messages, mais pour l’instant,
attendons que le consommateur puisse recevoir les messages.
13. Lancer le consommateur (consumer)
./bin/windows/[Link] --topic myFirstTopic --from-
beginning --bootstrap-server localhost:9092
14. Ecrivez un message dans producer
This is my first message
Kafka sert à envoyer des messages en temps réel