Modul ini membahas pemrosesan stream di dalam Kafka menggunakan pustaka Kafka Streams, yang menjalankan logika pemrosesan di dalam aplikasi tanpa menambah cluster terpisah. Topik-topiknya berurutan dari model pustaka dan topologi pemrosesan, primitif transformasi stateless, state store lokal beserta changelog topic-nya, sampai windowing yang membatasi agregasi pada rentang waktu tertentu. Posisinya pada jalur ini mengikuti modul Keandalan, karena konsep partisi, consumer group, dan changelog topic dari modul-modul sebelumnya menjadi bekal langsung bagi pemrosesan stateful pada modul ini.
Streams processing
Pemrosesan stream di dalam Kafka: model pustaka Kafka Streams, primitif transformasi, state store, dan windowing.
0/0 selesai
- Kafka Streams
Model pustaka Kafka Streams, topologi pemrosesan, dan posisinya dibandingkan pemroses eksternal seperti Flink dan Spark.
- Primitif stream
Operasi stateless pada KStream: map, filter, flatMap, join, dan groupBy beserta semantiknya.
- State store
State store lokal dengan RocksDB, changelog topic, dan pemulihan state saat aplikasi restart.
- Windowing
Window tumbling, hopping, dan session pada agregasi stream beserta perilaku akhir window.