Apache Kafka, gerçek zamanlı veri işleme olanağı sağlayan dağıtık bir olay akışı platformudur. Bu kılavuz, Spring Boot uygulamasında Kafka kullanarak JSON mesajlarının nasıl gönderilip tüketileceğini göstermektedir.
Apache Kafka, gerçek zamanlı veri işleme olanağı sağlayan dağıtık bir olay akışı platformudur. Bu kılavuz, Spring Boot uygulamasında Kafka kullanarak JSON mesajlarının nasıl gönderilip tüketileceğini göstermektedir.
Bu bölümde Neden Kafka Kullanılmalı? konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
📋 Aşağıdakilere sahip olduğunuzdan emin olun:
Kafka'yı Spring Boot projenize entegre etmek için aşağıdaki bağımlıkları ekleyin:
<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> </dependency>
implementation 'org.springframework.kafka:spring-kafka'
Kafka bağlantısını application.properties veya application.yml dosyasında yapılandırın:
spring.kafka.bootstrap-servers=localhost:9092 spring.kafka.consumer.group-id=my-group spring.kafka.consumer.auto-offset-reset=earliest spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer spring.kafka.consumer.properties.spring.json.trusted.packages=*
Bu bölümde Adım 3: JSON Mesajlar için Bir Model Oluşturun konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
Bu model, producer, consumer ve controller katmanları arasında taşınan mesaj sözleşmesini tanımlar.
Bu bölümde Adım 4: Kafka Producer ve Consumer Uygulamaları konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
Bu producer örneği, mesajların hedef topic’e nasıl tutarlı biçimde gönderileceğini gösterir.
Bu consumer örneği, gelen mesajların nasıl okunup işlendiğini açıkça gösterir.
Bu controller, mesaj akışını tetiklemek ve sonucu doğrulamak için sade bir API yüzeyi sağlar.
Uygulamayı aşağıdaki komutla çalıştırın:
./mvnw spring-boot:run
Kafka Producer apisini cURL veya Postman kullanarak test edebilirsiniz:
curl -X POST "http://localhost:8080/kafka/publish" \ -H "Content-Type: application/json" \ -d '{"id": "123", "content": "Hello Kafka!"}'
Artık Kafka Entegrasyonu için üretim odaklı bir Spring Boot temeliniz var. Sonraki adımda ayarları kendi domainine uyarlayıp test ve gözlemlenebilirlik katmanını ekleyerek gerçek trafik altında doğrulayın.
package com.example.kafka.model; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; @Data @NoArgsConstructor @AllArgsConstructor public class Message { private String id; private String content; }
package com.example.kafka.model data class Message( val id: String, val content: String )
package com.example.kafka.producer; import com.example.kafka.model.Message; import lombok.RequiredArgsConstructor; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.stereotype.Service; @Service @RequiredArgsConstructor public class KafkaProducer { private final KafkaTemplate<String, Message> kafkaTemplate; public void sendMessage(String topic, Message message) { kafkaTemplate.send(topic, message); } }
package com.example.kafka.producer import com.example.kafka.model.Message import org.springframework.kafka.core.KafkaTemplate import org.springframework.stereotype.Service @Service class KafkaProducer(private val kafkaTemplate: KafkaTemplate<String, Message>) { fun sendMessage(topic: String, message: Message) { kafkaTemplate.send(topic, message) } }
package com.example.kafka.consumer; import com.example.kafka.model.Message; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Service; @Service public class KafkaConsumer { @KafkaListener(topics = "my-topic", groupId = "my-group") public void consumeMessage(Message message) { System.out.println("Received message: " + message); } }
package com.example.kafka.consumer import com.example.kafka.model.Message import org.springframework.kafka.annotation.KafkaListener import org.springframework.stereotype.Service @Service class KafkaConsumer { @KafkaListener(topics = ["my-topic"], groupId = "my-group") fun consumeMessage(message: Message) { println("Received message: $message") } }
package com.example.kafka.controller; import com.example.kafka.model.Message; import com.example.kafka.producer.KafkaProducer; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; @RestController @RequestMapping("/kafka") @RequiredArgsConstructor public class KafkaController { private final KafkaProducer kafkaProducer; @PostMapping("/publish") public String publishMessage(@RequestParam String topic, @RequestBody Message message) { kafkaProducer.sendMessage(topic, message); return "Message sent to topic: " + topic; } }
package com.example.kafka.controller import com.example.kafka.model.Message import com.example.kafka.producer.KafkaProducer import org.springframework.web.bind.annotation.* @RestController @RequestMapping("/kafka") class KafkaController(private val kafkaProducer: KafkaProducer) { @PostMapping("/publish") fun publishMessage(@RequestParam topic: String, @RequestBody message: Message): String { kafkaProducer.sendMessage(topic, message) return "Message sent to topic: $topic" } }
