Memulai Apache Kafka dengan Spring Boot 1

Apache Kafka ditulis dalam bahasa pemrograman Scala dan Java oleh mantan data engineers di Linkedin pada awal 2011, kemudian teknologi ini diambil alih oleh komunitas sumber terbuka. Sekarang Apache Kafka adalah bagian dari  Confluent Stream Platform  yang menangani jutaan events setiap harinya dan digunakan oleh banyak perusahaan terkemuka.  

Untuk kali ini, mari kita mencoba untuk menggunakan Apache Kafka untuk melakukan Produce dan Consume messages dengan menggunakan Spring Boot.

Step 1 - Buat Project Spring Boot dengan Intializr

Buat Java Maven Project dengan menggunakan Spring Intializr sebagai berikut ini.

Step 2 - Masukan dependencies yang diperlukan pada project demokafka ini.

Generate dan download project sebagai berikut.

Step 3 - Extract dan Import ke Eclipse IDE (atau Java IDE apapun yang sesuai dan mendukung Maven).

Step 4 - Buat 3 Files, config, restcontroller dan model. Files tampak sebagai berikut.

Step 5 - KafkaConfig

Step 6 - KafkaController dengan Producer

Step 7 - UserModel

Step 8 - Post Request dengan Postman

Step 9 - Lihat Hasilnya dengan Conduktor

Step 10 - Lihat Videonya (Producer)

Step 10 - Source Codenya (Producer)

Kode ada di Github. 

Step 11 - Membuat Consumer

11.1 Rename KafkaConfig menjadi KafkaProducerConfig.

11.2 Buat file config baru bernama KafkaConsumerConfig.

11.2 Membuat Consumer Listener

11.2 Hasilnya di Video

Step 12 - Source Codenya (Consumer)

Kodenya ada di Github