Apache Kafka

Yüksek performanslı veri boru hatları için açık kaynaklı, dağıtılmış bir olay akışı platformu.

Önemli Dosyalar ve Dizinler

  • Ana Kafka kurulum dizini: /opt/kafka
  • Kafka broker yapılandırma dosyası: /opt/kafka/config/server.properties
  • Kafka günlük dizini (aracı günlükleri, saklanan olaylar): /opt/kafka/logs
  • Kafka ikili dosyaları ve CLI araçları (kafka-topics.sh, kafka-console-producer.sh, vb.): /opt/kafka/bin
  • Kafka'yı yönetmek için Systemd hizmet birimi: /etc/systemd/system/kafka.service

Kafka Hizmeti

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 (Mesajlar) Oluşturun

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

Her satıra bir olay yazın.

Basın Ctrl+C çıkmak için.

Etkinlikleri Tüket

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

Basın Ctrl+C okumayı bırakmak.

Olaylar, birden fazla istemci tarafından birden fazla kez tüketilebilir.

Günlükler ve Sorun Giderme

  • Kafka günlükleri: /opt/kafka/logs
  • Systemd günlüğü: sudo journalctl -u kafka -f
  • Bağlantı noktalarını kontrol edin 9092 (broker) ve 9093 (denetleyici) açıktır.

Başvuru Detayları