İ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.
