Fontos fájlok és könyvtárak
- A Kafka fő telepítési könyvtára:
/opt/kafka - A Kafka broker konfigurációs fájlja:
/opt/kafka/config/server.properties - A Kafka naplókönyvtára (broker naplók, tárolt események):
/opt/kafka/logs - Kafka binárisok és CLI eszközök (
kafka-topics.sh,kafka-console-producer.sh, stb.):/opt/kafka/bin - A Kafkát kezelő Systemd service unit:
/etc/systemd/system/kafka.service
Kafka Szolgáltatás
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Téma létrehozása
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Topik részleteinek ellenőrzése:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Események küldése (üzenetek)
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
Írj egy eseményt soronként.
Nyomj Ctrl+C kilépni.
Események felhasználása
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Nyomj Ctrl+C olvasás leállítása.
Az eseményeket több kliens is többször felhasználhatja.
Naplók és hibaelhárítás
- Kafka naplók:
/opt/kafka/logs - Systemd napló:
sudo journalctl -u kafka -f - Portok biztosítása
9092(broker) és9093(controller) nyitva vannak.
