Apache Kafka’nın Java ile kullanımı

696

Merhaba arkadaşlar,
Apache Kafka ile ilgili bilgiyi kurulum ve kullanımı hakkında bir önceki yazımda detaylı deyinmiştik.

Link: http://www.turkishh.com/programlama/kafka-nedir-kurulumu-ve-kullanimi/
Bu yazımda kafka ile javada procuder ve consumer yapan küçük bir uygulama yapacağız. Uygulamamız maven olacak springboot ile yapacağız uygulamamızı.Kafka’yı kullanabilmemiz için Java version 1.8 olması lazım.

Senaryomuz basit prodecure yapacak bir rest servis yazacağız. Servise istek attığımızda messajımızı parametre ile geçeceğiz ve kafka kütüphanelerini kullanarak producer yapacağız ve aynı şekilde producer ettiğimiz mesajımızı consumer edip konsola yazacağız. Ayrıyeten komut satırından da consumer edeceğiz.
İlk önce bağımlılıklarımızı tanımlayalım pom dosyamız şöyle olacak.

pom.xml

 

SpringBoot kullandığımız için uygulamamızı start edecek sınıfı yazıyoruz

Application.java

 

 

Sonrasında properties dosyamızı resources dizininde altına atıyoruz.

service.properties

 

Daha sonra KafkaConfig sınıfımızı yazıyoruz .

KafkaConfig.java

 

 

Prodecure yapabilmemiz için config sınıfını yazıyoruz.

KafkaProducerConfig.java

 

Consumer yapabilmemiz için bir başka config sınıfımızı yazıyoruz.

ConsumerConfiguration.java

 

 

Kafka producer yapabilmemiz için producer servisimizi yazıyoruz.

KafkaProducerService.java

 

 

 

Contoller sınıfımızı yazıyoruz.

KafkaProducerController.java

 

 

Uygulamamızı çalıştırdığımız zaman servisimize istek atmamız lazım producer işlemi için

http://localhost:8080/kafka/producer/<mesajımız>

 

Producer ettiğimizde çıktısını konsola bakabilirz yada bir önceki yazımdaki consumer ekranından görebiliriz.

 

çıktısı:

 

konsol çıktısı:

 

Proje Linki : ProjectsRelatedToKafka-master


Umarım yararlı olmustur

İyi ÇAlışmalar

Yorum yaz

Email adresiniz yayınlanmayacaktır.