... | @@ -45,6 +45,26 @@ Pareil que Zookeeper, on peut vérifier au préalable le fichier de configuratio |
... | @@ -45,6 +45,26 @@ Pareil que Zookeeper, on peut vérifier au préalable le fichier de configuratio |
|
|
|
|
|
==> 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.
|
|
|
|
|
|
|
|
**Lancement automatique des services**
|
|
|
|
|
|
|
|
Nous devons lancer automatiquement, et au démarrage du serveur les services Zookeeper et Kafka.
|
|
|
|
|
|
|
|
Pour cela, nous avons écrit dans le fichier "/etc/rc.d/rc.local" les lignes suivantes:
|
|
|
|
|
|
|
|
`# Démarrage de Zookeeper`
|
|
|
|
`nohup sudo /kafka_2.10-0.10.2.1/bin/zookeeper-server-start.sh /kafka_2.10-0.10.2.1/config/zookeeper.properties > /kafka_2.10-0.10.2.1/zookeeper-nohup.txt &`
|
|
|
|
|
|
|
|
`# Attente de démarrage complet de Zookeeper`
|
|
|
|
`# On va mettre 20 secondes pour commencer`
|
|
|
|
`sleep 20`
|
|
|
|
|
|
|
|
`# démarrage de Kafka`
|
|
|
|
`nohup sudo /kafka_2.10-0.10.2.1/bin/kafka-server-start.sh /kafka_2.10-0.10.2.1/config/server.properties > /kafka_2.10-0.10.2.1/kafka-nohup.txt &`
|
|
|
|
|
|
|
|
Ensuite, il faut le rendre exécutable :
|
|
|
|
|
|
|
|
`sudo chmod +x /etc/rc.d/rc.local`
|
|
|
|
|
|
**Création d'un topic "test"**
|
|
**Création d'un topic "test"**
|
|
|
|
|
|
Dans Kafka, un message est appelé "Record"; les records sont regroupés par "Topic" ou sujet.
|
|
Dans Kafka, un message est appelé "Record"; les records sont regroupés par "Topic" ou sujet.
|
... | | ... | |