Apache Kafka

Belangrijke bestanden en mappen

• Hoofdinstallatiemap van Kafka: /opt/kafka
• Configuratiebestand van de Kafka-broker: /opt/kafka/config/server.properties
• Logmap van Kafka (brokerlogs, bewaarde events): /opt/kafka/logs
• Kafka-binaries en CLI-tools (kafka-topics.sh, kafka-console-producer.sh, enz.): /opt/kafka/bin
• Systemd-service-unit voor het beheren van Kafka: /etc/systemd/system/kafka.service

Kafka-service

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

Een onderwerp maken

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

Bekijk topic-details:

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

Events produceren (berichten)

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

Typ één event per regel.

Druk Ctrl+C om af te sluiten.

Gebeurtenissen verbruiken

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

Druk Ctrl+C stoppen met lezen.

Events kunnen meerdere keren worden verwerkt door meerdere clients.

Logs en probleemoplossing

• Kafka-logboeken: /opt/kafka/logs
• Systemd journaal: sudo journalctl -u kafka -f
• Zorg voor poorten 9092 (makelaar) en 9093 (controller) zijn open.