- Bu örnekte Kafka ve NodeJS kullanılarak gerçek zamanlı veri üretme ve tüketme gösterilmektedir.
- Kafka'ya bağlanmak için KafkaJS kütüphanesi kullanılmıştır.
- Kafka Docker kapsayıcısı ile yüklenmektedir.
- Kapsayıcı ayarları docker-compose.yaml dosyasında yer almaktadır.
- 1 üretici, 2 tüketici mevcuttur.
- 1.tüketici "Yazilim-Muhendisligi" konusunu, 2.tüketici "Yazilim-Muhendisligi" ve "Web-Teknolojileri" konularını tüketmektedir.
- Mesaj akışları terminal ekranlarında gösterilmektedir.
npm install
komutu ile bağımlılıklar yüklenir.docker-compose up
ile Kafka kapsayıcısı çalıştırılır.- Üretici ve tüketiciler ayrı ayrı terminal ekranlarında çalıştırılır.
- Üreticiyi çalıştırmak için
npm run uretici
komutu kullanılır. - Tüketici-1'i çalıştırmak için
npm run tuketici-1
komutu kullanılır. - Tüketici-2'i çalıştırmak için
npm run tuketici-2
komutu kullanılır.