Apache Kafka
Apache Kafka dağıtılan akışlı bir platformdur.Akış sağlayan bir platformun üç önemli
özelliği;
Kayıt akışı yayınlamaya ve abone olmaya izin verir. Bu bakımdan, mesaj kuyruğuna veya
kurumsal mesajlaşma sistemine benzemektedir.
Kayıt akışlarını hataya dayanıklı bir şekilde saklamaya izin verir.
Kayıtların akışları gerçekleştikçe işleme konulmasını sağlar.
İki geniş uygulama sınıfı için kullanılır:
Sistemler veya uygulamalar arasında güvenilir bir şekilde veri toplayan gerçek zamanlı veri
akış hatları oluşturma
Verilerin akışlarına dönüşüm veya tepki veren gerçek zamanlı akış uygulamaları oluşturma
Kafka nasıl yapar bunları?
Kafka bir veya daha fazla sunucuda bir küme olarak çalıştırılır.
Kafka kümesi,kayıt akışı konular başlıklı kategorilerde saklar .
Her kayıt, bir anahtar, bir değer ve bir zaman damgasından oluşur.
Kafka’nın dört temel API’sı var:
Üretici API bir veya daha fazla Kafka konulara kayıtların bir akışı yayınlamak için bir
uygulama sağlar.
Tüketici API bir uygulama bir veya daha fazla konulara abone ve onlara üretilen kayıtların
akışı süreci sağlar.
Akım arayüzü bir uygulama olarak hareket sağlar akış işlemcisi etkili bir giriş çıkış akışları
akışları transforme edilmesi, bir veya daha fazla konu ile ilgili bir giriş akışı alan ve bir veya
daha fazla çıkış konulara bir çıkış akımının üretilmesi.
Bağlayıcı API’si bina ve mevcut uygulamalar veya veri sistemlerine Kafka konularını
bağlamak yeniden üreticileri ve tüketicileri çalıştıran sağlar. Örneğin, bir ilişkisel veritabanına
bir bağlayıcı, bir tabloya yapılan her değişikliği yakalayabilir.
Kafka’da, istemciler ve sunucular arasındaki iletişim, basit, yüksek performanslı, dil
agnostik TCP protokolüyle yapılır . Bu protokol sürümlendi ve eski sürüm ile geriye dönük
uyumluluğu sürdürüyor