Apache Kafka

Důležité soubory a adresáře

• Hlavní instalační adresář Kafky: /opt/kafka
• Konfigurační soubor brokera Kafka: /opt/kafka/config/server.properties
• Adresář protokolu Kafka (protokoly zprostředkovatele, uchované události): /opt/kafka/logs
• Kafka binární soubory a nástroje CLI (kafka-topics.sh, kafka-console-producer.shatd.): /opt/kafka/bin
• Servisní jednotka Systemd pro správu Kafky: /etc/systemd/system/kafka.service

Služba Kafka

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

Vytvořte téma

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

Zkontrolujte podrobnosti tématu:

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

Vytvořit události (zprávy)

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

Zadejte jednu událost na řádek.

Stiskněte Ctrl+C vystoupit.

Konzumovat události

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

Stiskněte Ctrl+C přestat číst.

Události mohou být spotřebovány vícekrát více klienty.

Protokoly a odstraňování problémů

• Kafka protokoly: /opt/kafka/logs
• Systemd journal: sudo journalctl -u kafka -f
• Zajistěte porty 9092 (zprostředkovatel) a 9093 (ovladač) jsou otevřené.