Önemli Dosyalar ve Dizinler
- Ana Kafka kurulum dizini:
/opt/kafka - Kafka aracısı yapılandırma dosyası:
/opt/kafka/config/server.properties - Kafka günlük dizini (aracı günlükleri, tutulan olaylar):
/opt/kafka/logs - Kafka ikili dosyaları ve CLI araçları (
kafka-topics.sh,kafka-console-producer.sh, vesaire.):/opt/kafka/bin - Kafka'yı yönetmek için Systemd hizmet birimi:
/etc/systemd/system/kafka.service
Kafka Servisi
sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka
Konu Oluştur
/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
Konu ayrıntılarını kontrol edin:
/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Etkinlikler Üretin (Mesajlar)
/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
Her satıra bir olay yazın.
Basmak Ctrl+C çıkmak için.
Etkinlikleri Tüket
/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
Basmak Ctrl+C okumayı bırakmak için.
Etkinlikler birden çok istemci tarafından birden çok kez tüketilebilir.
Günlükler ve Sorun Giderme
- Kafka'nın günlükleri:
/opt/kafka/logs - Sistem günlüğü:
sudo journalctl -u kafka -f - Bağlantı noktalarından emin olun
9092(komisyoncu) ve9093(kontrolör) açık.