Apache Kafka

Fichiers et répertoires importants

• Répertoire d'installation principal de Kafka : /opt/kafka
• Fichier de configuration du broker Kafka : /opt/kafka/config/server.properties
• Répertoire des logs Kafka (logs du broker, événements conservés) : /opt/kafka/logs
• Binaires Kafka et outils CLI (kafka-topics.sh, kafka-console-producer.sh, etc.) : /opt/kafka/bin
• Unité de service systemd pour gérer Kafka : /etc/systemd/system/kafka.service

Service Kafka

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

Créer un topic

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Vérifier les détails du topic :

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Produire des événements (messages)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Saisissez un événement par ligne.

Appuyez sur Ctrl+C pour quitter.

Consommer des événements

/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Appuyez sur Ctrl+C pour arrêter la lecture.

Les événements peuvent être consommés plusieurs fois par plusieurs clients.

Journaux & Dépannage

• Journaux Kafka : /opt/kafka/logs
• Journal systemd : sudo journalctl -u kafka -f
• Assurez-vous que les ports 9092 (broker) et 9093 (controller) sont ouverts.