Apache Kafka - Küme Mimarisi
Aşağıdaki resme bir göz atın. Kafka'nın küme diyagramını gösterir.
Aşağıdaki tablo, yukarıdaki diyagramda gösterilen bileşenlerin her birini açıklamaktadır.
| S.No | Bileşenler ve Açıklama |
|---|---|
| 1 |
Broker Kafka kümesi tipik olarak yük dengesini korumak için birden çok aracıdan oluşur. Kafka aracıları devletsizdir, bu nedenle küme durumlarını korumak için ZooKeeper kullanırlar. Bir Kafka komisyoncu örneği, saniyede yüz binlerce okuma ve yazma işleyebilir ve her bir aracı, performans etkisi olmadan TBC iletiyi işleyebilir. Kafka broker lideri seçimi ZooKeeper tarafından yapılabilir. |
| 2 |
ZooKeeper ZooKeeper, Kafka brokerini yönetmek ve koordine etmek için kullanılır. ZooKeeper hizmeti esas olarak üreticiyi ve tüketiciyi Kafka sisteminde yeni bir komisyoncunun varlığından veya Kafka sistemindeki komisyoncunun arızasından haberdar etmek için kullanılır. Zookeeper tarafından komisyoncunun varlığı veya başarısızlığı ile ilgili alınan bildirime göre, üretici ve tüketici karar alır ve diğer bir komisyoncu ile görevlerini koordine etmeye başlar. |
| 3 |
Producers Üreticiler, verileri aracılara aktarır. Yeni komisyoncu başlatıldığında, tüm üreticiler onu arar ve bu yeni komisyoncuya otomatik olarak bir mesaj gönderir. Kafka üreticisi, komisyoncunun onaylarını beklemez ve komisyoncunun yapabileceği en hızlı şekilde mesajlar gönderir. |
| 4 |
Consumers Kafka aracıları devletsiz olduğundan, bu, tüketicinin bölüm ofseti kullanarak kaç mesajın tüketildiğini sürdürmesi gerektiği anlamına gelir. Tüketici, belirli bir mesaj ofsetini kabul ederse, bu, tüketicinin önceki tüm mesajları tükettiği anlamına gelir. Tüketici, kullanıma hazır bayt arabelleğine sahip olmak için aracıya zaman uyumsuz bir çekme isteği gönderir. Tüketiciler, sadece bir ofset değeri sağlayarak bir bölümdeki herhangi bir noktaya geri sarabilir veya atlayabilir. Tüketici ofset değeri ZooKeeper tarafından bildirilir. |