Wichtige Dateien und Verzeichnisse
- Hauptinstallationsverzeichnis von Kafka:
/opt/kafka - Kafka-Broker-Konfigurationsdatei:
/opt/kafka/config/server.properties - Kafka-Protokollverzeichnis (Broker-Protokolle, beibehaltene Ereignisse):
/opt/kafka/logs - Kafka-Binärdateien und CLI-Tools (
kafka-topics.sh,kafka-console-producer.sh, usw.):/opt/kafka/bin - Systemd-Diensteinheit zur Verwaltung von Kafka:
/etc/systemd/system/kafka.service
Kafka-Dienst
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Erstelle ein Thema
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Überprüfe die Themendetails:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Ereignisse (Nachrichten) produzieren
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
Gib ein Ereignis pro Zeile ein.
Drücken Ctrl+C verlassen.
Ereignisse konsumieren
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Drücken Ctrl+C mit dem Lesen aufzuhören.
Ereignisse können von mehreren Clients mehrmals konsumiert werden.
Protokolle und Fehlerbehebung
- Kafka-Protokolle:
/opt/kafka/logs - Systemd-Journal:
sudo journalctl -u kafka -f - Stelle sicher, dass Ports vorhanden sind
9092(Makler) und9093(Regler) sind geöffnet.