|
|
Page Wiki sur le serveur de message
|
|
|
|
|
|
Installation de Apache KAFKA sur notre serveur virtuel:
|
|
|
**Installation de Apache KAFKA**
|
|
|
|
|
|
Sur notre serveur virtuel nous avons entré les commandes suivantes:
|
|
|
|
|
|
`yum install wget`
|
|
|
|
... | ... | @@ -10,18 +12,19 @@ Installation de Apache KAFKA sur notre serveur virtuel: |
|
|
|
|
|
`cd kafka_2.10-0.10.2.1/`
|
|
|
|
|
|
Maintenant que nous avons installé le package kafka, qui va gérer la file de messages, nous devons installer un zookeeper. Celui-ci est en charge de réaliser la synchronisation des différents éléments d'un cluster.
|
|
|
Maintenant que nous avons installé le package kafka, qui va gérer la file de messages, nous devons installer un zookeeper.
|
|
|
|
|
|
Zookeeper fonctionne sur la base de JAVA, il faut au préalable vérifier que ce dernier est fonctionnel sur notre serveur:
|
|
|
Celui-ci est en charge de réaliser la synchronisation des différents éléments d'un cluster. Il fonctionne sur la base de JAVA, il faut au préalable vérifier que ce dernier est fonctionnel sur notre serveur:
|
|
|
|
|
|
`yum install java-1.8.0-openjdk-devel`
|
|
|
|
|
|
La version kafka téléchargée auparavant contient les binaires de Apache Zookeeper.
|
|
|
On peut vérifier sa configuration dans le dossier suivant :
|
|
|
La version kafka téléchargée auparavant contient les binaires de Apache Zookeeper, on peut vérifier sa configuration dans le dossier suivant :
|
|
|
|
|
|
`config/zookeeper.properties`
|
|
|
|
|
|
Il ne nous reste plus qu'à le lancer:
|
|
|
**Lancement des services**
|
|
|
|
|
|
Il ne nous reste plus qu'à lancer le service de zookeeper avec la commande suivante :
|
|
|
|
|
|
`./bin/zookeeper-server-start.sh ./config/zookeeper.properties`
|
|
|
|
... | ... | @@ -46,7 +49,9 @@ Trying 127.0.0.1... |
|
|
Connected to localhost`
|
|
|
|
|
|
|
|
|
==> Nous voilà avec un Zookeeper et un broker Kafka, qui représent un cluster Kafka minimal
|
|
|
==> Nous voilà avec un Zookeeper et un broker Kafka, qui représent un cluster Kafka minimal.
|
|
|
|
|
|
**Création d'un topic "test"**
|
|
|
|
|
|
Dans Kafka, un message est appelé "Record"; les records sont regroupés par "Topic" ou sujet.
|
|
|
On va tout d'abord créé par exemple un topic "test" grâce à un script disponible:
|
... | ... | @@ -63,16 +68,18 @@ Ou même afficher les détails du topic: |
|
|
|
|
|
`./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test`
|
|
|
|
|
|
**Echange de messages entre producteurs et consommateurs**
|
|
|
|
|
|
Dans Kafka, les messages sont produits par des producers (ou producteurs) et consommés par des consumers (ou consommateurs). On peut "écrire" et "lire" des records (donc message) de la manière suivante:
|
|
|
|
|
|
Sur le producer:
|
|
|
Sur le producteur :
|
|
|
A savoir => Chaque ligne que l'on écrit après cette commande sera considérée comme un message
|
|
|
|
|
|
`./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test`
|
|
|
|
|
|
`Bonjour comment allez-vous?`
|
|
|
|
|
|
Sur le consumer:
|
|
|
Sur le consommateur :
|
|
|
|
|
|
`./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test`
|
|
|
|
... | ... | |