Kayıt Ol

Giriş

Şifremi Kaybettim

Lost your password? Please enter your email address. You will receive a link and will create a new password via email.

soru ekleme

Soru sormak için giriş yapmalısınız.

Giriş

Kayıt Ol

.........

Spring Boot – Apache Kafka

Spring Boot – Apache Kafka

Apache Kafka, hataya dayanıklı mesajlaşma sistemine dayalı mesajları yayınlamak ve abone olmak için kullanılan açık kaynaklı bir projedir. Tasarım, hızlı, ölçeklenebilir ve dağıtılmıştır. 

Bu bölümde, Spring Boot uygulamasında Apache Kafka’nın nasıl uygulanacağını göreceğiz.

Öncelikle, Spring Kafka bağımlılığını build configuration dosyamıza eklemeliyiz.

Maven kullanıcıları pom.xml dosyasına şu bağımlılığı ekleyebilir.

Gradle kullanıcıları build.gradle dosyasına aşağıdaki bağımlılığı ekleyebilir.

Mesaj üretmek

Apache Kafka’ya mesaj üretmek için, Producer konfigürasyonu için Configuration class’ı gösterildiği gibi tanımlamamız gerekir –

Bir mesajı yayınlamak için Kafka Template nesnesini otomatik olarak bağlayın ve mesajı gösterildiği gibi oluşturun.

Mesajı Uygulayın

Mesajları uygulamak için, aşağıda gösterildiği gibi bir Consumer configuration class dosyası yazmamız gerekir.

Sonra mesajları dinlemek için bir Listener yazın.

Main Spring Boot uygulama class dosyasındaki ApplicationRunner class’ından runMessage() methodunu çağıralım ve aynı class dosyasındaki mesajı kullanalım.

Main Spring Boot uygulama class dosya kodunuz aşağıda verilmiştir –

Komple build configuration dosyasının kodu aşağıda verilmiştir.
Maven – pom.xml

Gradle – build.gradle

 

Hakkında Hilal Saim

Namık Kemal Üniversitesi/Bilgisayar Mühendisliği

Beni Takip Et

Leave a reply

*