Fichiers et répertoires importants
- Répertoire d'installation principal de Kafka :
/opt/kafka - Fichier de configuration du courtier Kafka :
/opt/kafka/config/server.properties - Répertoire des journaux Kafka (journaux du courtier, é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 la gestion de Kafka :
/etc/systemd/system/kafka.service
Service Kafka
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Créer un sujet
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Vérifiez les détails du sujet :
/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
Tapez un événement par ligne.
Presse Ctrl+C pour sortir.
Consommer des événements
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Presse Ctrl+C arrêter de lire.
Les événements peuvent être consommés plusieurs fois par plusieurs clients.
Journaux et dépannage
- Journaux Kafka :
/opt/kafka/logs - Journal système :
sudo journalctl -u kafka -f - Assurer les ports
9092(courtier) et9093(contrôleur) sont ouverts.
