Simple Event Stream App

Repository ini adalah sebagai bahan untuk mempelajari konsep dan cara kerja event stream architecture dengan real time case

Producer

Bertugas untuk generate nilai Long secara random dari angka 1 sampai 1000 kemudian mengirimkan data tersebut ke kafka dengan topic numbers
Processor

Menerima data dari kafa dengan topic numbers kemudian memproses angkanya dengan melakukan filter angka genap dan melakukan operasi pengkalian v = v * v, kemudian mengirimkan kembali ke kafka dengan topic squaredNumbers
Consumer

Menerima data dari kafka dengan topic squaredNumbers dan menampilkan dalam console.

Prerequisites

Sebelum mencoba repo ini pastikan local anda sudah terinstall :

Setelah anda menjalankan zookeeper dan kafka server nya buatlah dua topic berikut :

kafka-topics --zookeeper 127.0.0.1:2181 --topic numbers --create --partitions 1 --replication-factor 1

kafka-topics --zookeeper 127.0.0.1:2181 --topic squaredNumbers --create --partitions 1 --replication-factor 1

jvmdeveloperid/spring-boot-kafka-stream