Apache Kafka

Belangrijke bestanden en mappen

• Hoofdinstallatiemap van Kafka: /opt/kafka
• Configuratiebestand van Kafka-makelaar: /opt/kafka/config/server.properties
• Kafka-logboekmap (brokerlogboeken, bewaarde gebeurtenissen): /opt/kafka/logs
• Kafka-binaire bestanden en CLI-tools (kafka-topics.sh, kafka-console-producer.shenz.): /opt/kafka/bin
• Systemd-service-eenheid voor het beheer van Kafka: /etc/systemd/system/kafka.service

Kafka-service

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

Creëer een onderwerp

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

Controleer onderwerpdetails:

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

Produceer evenementen (berichten)

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

Typ één gebeurtenis per regel.

Druk op Ctrl+C om af te sluiten.

Consumeer evenementen

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

Druk op Ctrl+C om te stoppen met lezen.

Evenementen kunnen meerdere keren door meerdere clients worden geconsumeerd.

Logboeken en probleemoplossing

• Kafka logt: /opt/kafka/logs
• Systeemjournaal: sudo journalctl -u kafka -f
• Zorg voor poorten 9092 (makelaar) en 9093 (controleur) zijn geopend.