پروجیکٹ Apache Kafka میں انضمام Node.js

Apache Kafka کسی پروجیکٹ میں ضم ہونے سے Node.js آپ کو ریئل ٹائم ایپلی کیشنز بنانے کی اجازت ملتی ہے جو کافکا کی ڈیٹا پروسیسنگ کی صلاحیتوں سے فائدہ اٹھاتی ہیں۔ Apache Kafka کسی پروجیکٹ میں ضم کرنے کے بارے میں یہاں ایک بنیادی گائیڈ ہے Node.js:

مرحلہ 1: کے لیے کافکا لائبریری انسٹال کریں۔ Node.js

Node.js اپنی پروجیکٹ ڈائرکٹری میں ٹرمینل کھولیں ۔

لائبریری کو انسٹال کرنے کے لیے درج ذیل کمانڈ کو چلائیں kafkajs ، Node.js اس کے لیے ایک لائبریری Apache Kafka: npm install kafkajs.

مرحلہ 2: کافکا کے ساتھ بات چیت کرنے کے لیے کوڈ لکھیں۔ Node.js

kafkajs لائبریری کو اپنے کوڈ میں درآمد کریں Node.js:

const { Kafka } = require('kafkajs');

ترتیب کے پیرامیٹرز کی وضاحت کریں Kafka Broker:

const kafka = new Kafka({  
  clientId: 'your-client-id',  
  brokers: ['broker1:port1', 'broker2:port2'], // Replace with actual addresses and ports  
});  

پیغامات بھیجنے کے لیے ایک بنائیں producer:

const producer = kafka.producer();  
  
const sendMessage = async() => {  
  await producer.connect();  
  await producer.send({  
    topic: 'your-topic',  
    messages: [{ value: 'Hello Kafka!' }],  
  });  
  await producer.disconnect();  
};  
  
sendMessage();  

پیغامات وصول کرنے کے لیے ایک بنائیں consumer:

const consumer = kafka.consumer({ groupId: 'your-group-id' });  
  
const consumeMessages = async() => {  
  await consumer.connect();  
  await consumer.subscribe({ topic: 'your-topic', fromBeginning: true });  
  
  await consumer.run({  
    eachMessage: async({ topic, partition, message }) => {  
      console.log(`Received message: ${message.value}`);  
    },  
  });  
};  
  
consumeMessages();  

نوٹ: قدروں کو تبدیل کریں جیسے 'your-client-id', 'broker1:port1', 'your-topic', اور 'your-group-id' اپنی اصل پروجیکٹ کی معلومات سے۔

ذہن میں رکھیں کہ آپ کی مخصوص ضروریات کی بنیاد پر Apache Kafka اس میں ضم ہونا زیادہ پیچیدہ ہو سکتا ہے۔ کنفیگریشن کے اختیارات اور افعال کے بارے میں مزید سمجھنے کے لیے لائبریری Node.js کی آفیشل دستاویزات Apache Kafka اور اس کا حوالہ دینا یقینی بنائیں۔ kafkajs