সঙ্গে স্থায়িত্ব এবং সামঞ্জস্য ব্যবস্থাপনা 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 ।