Hapi 1: Instaloni Bibliotekën Kafka për Node.js
Hapni një terminal në drejtorinë e projektit tuaj Node.js.
Ekzekutoni komandën e mëposhtme për të instaluar kafkajs
bibliotekën, një Node.js bibliotekë për Apache Kafka: npm install kafkajs
.
Hapi 2: Dërgimi i mesazheve me Producer in Node.js
Importoni kafkajs
bibliotekën dhe përcaktoni Kafka Broker konfigurimin:
Krijoni një producer për të dërguar mesazhe dhe dërgoni një mesazh te një topic:
Hapi 3: Marrja e mesazheve me Consumer in Node.js
Importoni kafkajs
bibliotekën dhe përcaktoni Kafka Broker konfigurimin(nëse nuk është bërë tashmë):
Krijo një consumer për të marrë mesazhe nga një specifik topic:
Shënim: Zëvendësoni vlerat si 'your-client-id'
, 'broker1:port1'
, 'your-topic'
, dhe 'your-group-id'
me informacionin aktual të projektit tuaj.
Sigurohuni që t'i referoheni dokumentacionit zyrtar Apache Kafka dhe kafkajs
bibliotekës për më shumë informacion rreth opsioneve dhe funksionaliteteve të konfigurimit.