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