Modul ini membahas interaksi klien dengan broker Kafka, mulai dari konfigurasi producer beserta alur pengirimannya, pemilihan partisi lewat key, koordinasi consumer group, pengelolaan offset, rebalancing, sampai header dan metadata pesan. Setiap mekanisme diuji pada broker lokal atau melalui simulasi yang dapat dihitung ulang, dengan keluaran nyata yang ditempel pada pembahasannya. Setelah modul ini selesai, perilaku producer dan consumer dapat dijelaskan dari konfigurasinya serta diawasi dengan perintah CLI.
Producer dan consumer
Interaksi klien dengan broker: konfigurasi producer, key dan partisi, consumer group, pengelolaan offset, rebalancing, dan header pesan.
0/0 selesai
- Memproduksi pesan
Konfigurasi dasar producer, alur send sampai batch terkirim, dan serialisasi nilai pesan pada klien Python.
- Key dan partisi
Hashing key dengan murmur2, jaminan pengurutan per partisi, dan strategi memilih key yang sehat.
- Consumer group
Koordinasi consumer group: distribusi partisi ke anggota, pembagian beban, dan identitas group.
- Offset dan commit
Strategi commit offset, perintah seeking, reset offset, dan replay data dari awal log.
- Rebalancing
Pemicu rebalancing, biaya pemutaran konsumsi, dan protokol kooperatif yang memangkas pekerjaan ulang.
- Header dan metadata
Header pesan untuk metadata tambahan, timestamp yang dipilih broker, dan hook interceptor pada producer.