Comment lancer un serveur Kafka

Lancement d'un serveur Kafka

Dans cette page nous verrons comment lancer un serveur Kafka. J'utiliserais ici une installation Kafka 2.13-3.4.0 sur une machine Windows 10.

Les commandes pour les machines sous Linux sont presques similaires: par exmeple nos fichiers ne seront pas en .bat mains en .sh

Dans toute la suite de cette page, on considère que l'archive contenant les fichiers serveurs sont dans un fichier 'kafka' dont la chemin est C:\Tool.

Nous ouvrirons alors des invites de commandes dans le répertoire courants suivants:

C:\Tool\kafka\bin\windows

Lancement d'un serveur Zoookeeeper

Pour lancer un serveur Zookeeper, il suffit d'exécuter la commande suivante:

zookeeper-server-start.bat ..\..\config\zookeeper.properties

Pour l'arrêter, faire la commande suivante:

zookeeper-server-stop.bat

Lancement d'un serveur Kafka

Pour lancer un serveur Kafka, il suffit d'exécuter la commande suivante:

kafka-server-start.bat ..\..\config\server.properties

Pour l'arrêter, faire la commande suivante:

kafka-server-stop.bat

Recommendation

Il faut d'abord lancer le serveur Zookeeper, puis Kafka. Et pour éteindre les services, on éffectue l'extinction dans le sens inverse: d'abords Kafka puis Zookeeper.

Si vous voulez lancer de multiples serveurs, il est alors conseillé de créer des copies des fichiers en .properties en changeant les paramètres.

Commandes utiles

Dans cette parties, nous verrons des commandes simples pour l'installation d'un service Kafka.

Topic

Commande pour créer un topic:

kafka-topics.bat --create --topic NomTopic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

Commande pour lister tous les topics:

kafka-topics.bat --bootstrap-serveur=localhost:9092 --list

Commande pour lister tous les partitions d'un topic:

kafka-topics.bat --bootstrap-serveur=localhost:9092 --describe --topic NomTopic

Commande pour supprimer un topic:

kafka-topics.bat --bootstrap-serveur=localhost:9092 --delete --topic NomTopic

Attention: La suppression est désactivée par défaut, il faut rajouter dans le fichier de configuration la ligne suivante:
delete.topic.enable=true

Création d'un Producer

Pour créer un producer qui enverra des données dans un topic voulu, il faut exécuter la commande suivante:

kafka-console-producer.bat --broker-list localhost:9092 --topic NomTopic

Création d'un Consumer

Pour créer un consumer qui lira des données dans un topic voulu, il faut exécuter la commande suivante:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic NomTopic