close

اندر کے ساتھ استحکام اور مستقل مزاجی کا انتظام Apache Kafka Node.js

استحکام کا انتظام

اس میں نقل اور تقسیم کو ترتیب دینا Kafka: ایک بناتے وقت ، آپ اس کے ساتھ ساتھ topic پارٹیشنز کی تعداد بھی بتا سکتے ہیں ۔ یہ ہر ایک کے لیے نقل کی تعداد ہے ، جو بروکرز کی تعداد کا تعین کرتی ہے جس پر ہر پیغام کو نقل کیا جائے گا۔ topic replication factor replication factor partition

مثال: فرض کریں کہ آپ کے پاس orders topic 3 پارٹیشنز کے ساتھ اور replication factor 2 کا ایک ہے۔ اس کا مطلب ہے کہ ہر پیغام کو 2 مختلف بروکرز پر نقل کیا جائے گا۔ اگر کسی کو broker ناکامی کا سامنا کرنا پڑتا ہے، تب بھی آپ باقی سے پیغامات تک رسائی حاصل کر سکتے ہیں broker ۔

مستقل مزاجی کو یقینی بنانا

پیغامات بھیجنے اور وصول کرتے وقت تسلیم کرنے کا طریقہ کار: میں Apache Kafka ، آپ درستگی اور پائیداری کو یقینی بنانے کے لیے پیغامات بھیجتے اور وصول کرتے وقت اعترافی طریقہ کار استعمال کر سکتے ہیں۔ یہ طریقہ کار اس بات کو یقینی بناتا ہے کہ پیغامات کامیابی کے ساتھ بھیجے گئے ہیں یا اس سے پہلے کہ آپ مزید کارروائیوں کو آگے بڑھائیں اس کا اعتراف کر لیا گیا ہے۔

مثال: پیغامات بھیجتے وقت، آپ acks تسلیم کنفیگریشن کی وضاحت کے لیے اختیار استعمال کر سکتے ہیں۔ مثال کے طور پر، acks: 1 اس بات کو یقینی بناتا ہے کہ پیغام کامیابی کے ساتھ لیڈر کو بھیج دیا گیا broker ہے partition ۔ تصدیق کا انتظار کرنے سے، آپ کو پتہ چل جائے گا کہ دوسرے کاموں کو جاری رکھنے سے پہلے کب کوئی پیغام محفوظ طریقے سے محفوظ کیا گیا ہے۔ 

const { Kafka } = require('kafkajs');  
  
const kafka = new Kafka({  
  clientId: 'your-client-id',  
  brokers: ['broker1:port1', 'broker2:port2'],  
});  
  
const producer = kafka.producer();  
  
const sendMessages = async() => {  
  await producer.connect();  
  await producer.send({  
    topic: 'your-topic',  
    messages: [{ value: 'Hello Kafka!' }],  
    acks: 1, // Acknowledge after the message is successfully sent  
  });  
  await producer.disconnect();  
};  
  
sendMessages();

نوٹ:

  • اپنے پروجیکٹ کی اصل معلومات کے ساتھ 'your-client-id', 'broker1:port1', , اور دیگر اقدار کو تبدیل کرنا یقینی بنائیں ۔ 'your-topic'
  • کنفیگریشن کے اختیارات اور تسلیم کرنے کے طریقہ کار مخصوص پروجیکٹ کی ضروریات کے لحاظ سے مختلف ہو سکتے ہیں۔

تقسیم کاری، نقل تیار کرنے، تسلیم کرنے کے طریقہ کار کا استعمال کرتے ہوئے، اور نقل کے اختیارات کو ترتیب دے کر، آپ Apache Kafka استعمال کرتے وقت استحکام اور مستقل مزاجی کو یقینی بنانے کا مؤثر طریقے سے انتظام کر سکتے ہیں Node.js ۔