... | @@ -5,11 +5,8 @@ Page Wiki sur le serveur de message |
... | @@ -5,11 +5,8 @@ Page Wiki sur le serveur de message |
|
Sur notre serveur virtuel nous avons entré les commandes suivantes:
|
|
Sur notre serveur virtuel nous avons entré les commandes suivantes:
|
|
|
|
|
|
`yum install wget`
|
|
`yum install wget`
|
|
|
|
|
|
`wget http://apache.crihan.fr/dist/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz`
|
|
`wget http://apache.crihan.fr/dist/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz`
|
|
|
|
|
|
`tar xzf kafka_2.10-0.10.2.1.tgz`
|
|
`tar xzf kafka_2.10-0.10.2.1.tgz`
|
|
|
|
|
|
`cd kafka_2.10-0.10.2.1/`
|
|
`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.
|
|
Maintenant que nous avons installé le package kafka, qui va gérer la file de messages, nous devons installer un zookeeper.
|
... | @@ -31,9 +28,7 @@ Il ne nous reste plus qu'à lancer le service de zookeeper avec la commande suiv |
... | @@ -31,9 +28,7 @@ Il ne nous reste plus qu'à lancer le service de zookeeper avec la commande suiv |
|
Zookeeper est un serveur avec lequel on peut communiquer sur le port 2181. On peut donc vérifier que Zookeeper a été correctement lancé avec un petit appel telnet:
|
|
Zookeeper est un serveur avec lequel on peut communiquer sur le port 2181. On peut donc vérifier que Zookeeper a été correctement lancé avec un petit appel telnet:
|
|
|
|
|
|
`telnet localhost 2181`
|
|
`telnet localhost 2181`
|
|
|
|
|
|
`Trying 127.0.0.1...`
|
|
`Trying 127.0.0.1...`
|
|
|
|
|
|
`Connected to localhost`
|
|
`Connected to localhost`
|
|
|
|
|
|
Maintenant que le Zookeeper est lancé, nous pouvons lancer le service kafka:
|
|
Maintenant que le Zookeeper est lancé, nous pouvons lancer le service kafka:
|
... | @@ -43,9 +38,7 @@ Maintenant que le Zookeeper est lancé, nous pouvons lancer le service kafka: |
... | @@ -43,9 +38,7 @@ Maintenant que le Zookeeper est lancé, nous pouvons lancer le service kafka: |
|
Pareil que Zookeeper, on peut vérifier au préalable le fichier de configuration de Kafka. On sait qu'il écoute sur le port 9092:
|
|
Pareil que Zookeeper, on peut vérifier au préalable le fichier de configuration de Kafka. On sait qu'il écoute sur le port 9092:
|
|
|
|
|
|
`telnet localhost 9092`
|
|
`telnet localhost 9092`
|
|
|
|
|
|
`Trying 127.0.0.1...`
|
|
`Trying 127.0.0.1...`
|
|
|
|
|
|
`Connected to localhost`
|
|
`Connected to localhost`
|
|
|
|
|
|
|
|
|
... | | ... | |