SpringKafka Producer Kullanımı

Giriş

1. Kafka'ya mesaj göndermek için applicaton.properties ayarları yapılır. Eğer bu yapılmayacaksa ProducerFactory nesnesi yaratılmalıdır. ProducerFactory bir arayüz olduğu için aslında DefaultKafkaProducerFactory nesnesi yaratmak gerekir.

Açıklaması şöyle

To create messages, first, we need to configure a ProducerFactory which sets the strategy for creating Kafka Producer instances.

Then we need a KafkaTemplate which wraps a Producer instance and provides convenience methods for sending messages to Kafka topics.

Producer instances are thread-safe and hence using a single instance throughout an application context will give higher performance. Consequently, KakfaTemplate instances are also thread-safe and use of one instance is recommended.

2. Mesaj göndermek için KafkaTemplate kullanılır. Farklı topic'lere farklı mesaj tipleri göndermek için, o mesaj tipine mahsus KafkaTemplate yaratmak gerekir. KafkaTemplate.send() metodu ListenableFuture döndürdüğü için send() işleminin bitmesi yani sonucu da beklenebilir.

Maven

Şu satırı dahil ederiz

<properties>
  <kafka.version>2.6.1</kafka.version>
</properties>

<dependency>
  <groupId>org.springframework.kafka</groupId>
  <artifactId>spring-kafka</artifactId>
  <version>${kafka.version}</version>
</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
<dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-clients</artifactId>
  <version>${kafka.version}</version>
</dependency>