Kafka installation en local

Préparation

Préparation du système de paquets du système.

$ sudo su -
# apt-get update -y

Installation des pré-requis.

# apt-get install zookeeperd -y

Vérification du bon fonctionnement de zookeeper.

# fuser -n tcp 2181

Installation

Récupération de l'archive sur le site officiel.

$ cd Downloads
$ wget http://apache.crihan.fr/dist/kafka/2.0.0/kafka_2.12-2.0.0.tgz

Installation de kafka sur le système

# mkdir /opt/kafka
# tar -xvf kafka_2.12-2.0.0.tgz -C /opt/kafka

Configuration mono-broker

# ln -s /opt/kafka/kafka_2.12-2.0.0 /opt/kafka/latest
# echo "export PATH=$PATH:/opt/kafka/latest/bin" >> ~/.bashrc
# source ~/.bashrc
# kafka-server-start.sh /opt/kafka/latest/config/server.properties

Vérification du bon fonctionnement

Dans une autre console écrire :

Producteur

# kafka-console-producer.sh --broker-list localhost:9092 --topic testing
> Ceci est un premier message
> Ceci est un second message

Dans une nouvelle console écrire :

Consommateur

# kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testing --from-beginning