Wichtige Dateien und Verzeichnisse
- Hauptinstallationsverzeichnis von Kafka:
/opt/kafka - Konfigurationsdatei des Kafka-Brokers:
/opt/kafka/config/server.properties - Kafka-Protokollverzeichnis (Broker-Logs, gespeicherte Events):
/opt/kafka/logs - Kafka-Binärdateien und CLI-Tools (
kafka-topics.sh,kafka-console-producer.sh, usw.):/opt/kafka/bin - Systemd-Service-Unit zur Verwaltung von Kafka:
/etc/systemd/system/kafka.service
Kafka-Dienst
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Thema erstellen
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Topic-Details prüfen:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Events (Nachrichten) erzeugen
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
Geben Sie ein Event pro Zeile ein.
Drücken Sie Ctrl+C zum Beenden.
Ereignisse verarbeiten
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Drücken Sie Ctrl+C zum Lesen beenden.
Events können von mehreren Clients mehrfach konsumiert werden.
Protokolle & Fehlerbehebung
- Kafka-Protokolle:
/opt/kafka/logs - Systemd-Protokoll:
sudo journalctl -u kafka -f - Häfen sicherstellen
9092(Broker) und9093(controller) sind offen.