ขั้นตอนที่ 1: ติดตั้ง Kafka Library สำหรับ Node.js
เปิด a terminal ใน Node.js ไดเรกทอรีโครงการ ของคุณ
รันคำสั่งต่อไปนี้เพื่อติดตั้ง ไลบรารี kafkajs
ไลบรารี Node.js สำหรับ Apache Kafka: npm install kafkajs
ขั้นตอนที่ 2: การส่งข้อความด้วย Producer in Node.js
นำเข้า kafkajs
ไลบรารีและกำหนด Kafka Broker คอนฟิกูเรชัน:
สร้าง a producer เพื่อส่งข้อความ และส่งข้อความไปที่ topic:
ขั้นตอนที่ 3: การรับข้อความด้วย Consumer in Node.js
นำเข้า kafkajs
ไลบรารีและกำหนด Kafka Broker คอนฟิกูเรชัน(หากยังไม่ได้ดำเนินการ):
สร้าง consumer เพื่อรับข้อความจากเฉพาะ topic:
หมายเหตุ: แทนที่ค่าต่างๆ เช่น 'your-client-id'
, 'broker1:port1'
, 'your-topic'
, และ 'your-group-id'
ด้วยข้อมูลโครงการจริงของคุณ
ตรวจสอบให้แน่ใจว่าได้อ้างอิงเอกสารอย่างเป็นทางการของ Apache Kafka และ kafkajs
ไลบรารีสำหรับข้อมูลเพิ่มเติมเกี่ยวกับตัวเลือกการกำหนดค่าและฟังก์ชันการทำงาน