Apache Kafka

Fontos fájlok és könyvtárak

• Kafka fő telepítési könyvtár: /opt/kafka
• Kafka bróker konfigurációs fájl: /opt/kafka/config/server.properties
• Kafka naplókönyvtár (brókernaplók, megőrzött események): /opt/kafka/logs
• Kafka bináris fájlok és CLI eszközök (kafka-topics.sh, kafka-console-producer.sh, stb.): /opt/kafka/bin
• Systemd szolgáltatás egység Kafka kezeléséhez: /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

A téma részleteinek ellenőrzése:

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

Események létrehozása (üzenetek)

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

Írjon be egy eseményt soronként.

Sajtó Ctrl+C kilépéshez.

Események fogyasztása

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

Sajtó Ctrl+C hogy abbahagyja az olvasást.

Az eseményeket több ügyfél többször is felhasználhatja.

Naplók és hibaelhárítás

• Kafka naplófájlok: /opt/kafka/logs
• Systemd napló: sudo journalctl -u kafka -f
• Biztosítsa a portokat 9092 (bróker) és 9093 (vezérlő) nyitva vannak.