Tanım: Uygulamalar arasında veri akışını için kullanılan bir streaming platformu. Bir producer ürettiği mesajı Kafka'ya ekler ve bir veya daha fazla Consumer mesajları buradan sıralı bir şekilde alır. Rabbit MQ, Active MQ gibi ürünlere mesajlaşma amacıyla da kullanılabilir.

Kafka'ya rest servisleri üzerinden erişilmesini sağlayan bir proje

Node.js için geliştirmiş bir kafka client'ı

Node.js için geliştirmiş bir kafka client'ı

Node.js için geliştirmiş bir kafka client'ı

Node.js için geliştirmiş bir kafka client'ı. Kafka'ya , C/C++ ile yazılmış Kafka client kütüphanesi olan librdkafka üzerinden erişmektedir.

Node.js için geliştirmiş kafka client'ları olan kafka-node ve node-rdkafka projeleri karşılaştırılıyor.

İlk iş olarak kafka.apache.org sitesinden download linkine tıklanır. Binary downloads altındaki son versiyon indirilebilir. Zip dosyası indirildikten sonra bir dizine açılır. Dizin içinde bin, conf, logs gibi alt dizinler görülecektir.
İlk önce Zookeeper çalıştırılmalıdır. Komut satırından önce

cd \kafka_

ile Kafka'nın dizinine geçilir. Aşağıdaki gibi bin\windows altındaki zookeeper-server-start uygulaması çalıştırılır:

bin\windows\zookeeper-server-start config\zookeeper.properties

Zookeeper açıldıktan sonra benzer bir şekilde :

bin\windows\kafka-server-start config\server.properties

kafka server başlatılır. Artık Kafka kullanılabilir durumdadır.
Kurulumu test etmek için topic yaratıp, bir mesaj ekleyelim. Sonra da o mesajı alalım.

bin\windows\kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

ile test adında bir topic yaratabiliriz. Topic listesi aşağıdaki gibi alınabilir :

bin\windows\kafka-topics --list --bootstrap-server localhost:9092

Yukarıdaki komut sonucu ekranda yarattığımız topic'in adı gözükecektir.
Şimdi o topic'e bir mesaj ekleyelim.

kafka_2.12-2.5.0>bin\windows\kafka-console-producer --bootstrap-server localhost:9092 --topic test
>Merhaba1
>Merhaba2

kafka-console-producer komutu sizden bir mesaj girmenizi bekler. Görüldüğü gibi iki mesaj ekledik ve sonrada çıktık.
Şimdi de bu mesajları okuyalım.

kafka_2.12-2.5.0>bin\windows\kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning
Merhaba1
Merhaba2

Komut çalıştırıldığında eklediğimiz iki mesajda ekranda gözükecektir.