Apache Kafka मध्ये संदेश पाठवणे आणि प्राप्त करणे Node.js

पायरी 1: यासाठी काफ्का लायब्ररी स्थापित करा Node.js

terminal तुमच्या प्रकल्प निर्देशिकेत उघडा Node.js.

लायब्ररी स्थापित करण्यासाठी खालील आदेश चालवा kafkajs, Node.js यासाठी लायब्ररी Apache Kafka: npm install kafkajs.

Producer पायरी 2: मध्ये संदेश पाठवणे Node.js

लायब्ररी आयात करा kafkajs आणि Kafka Broker कॉन्फिगरेशन परिभाषित करा:

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

संदेश पाठवण्यासाठी एक तयार करा producer आणि एक संदेश पाठवा topic:

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

पायरी 3: Consumer मध्ये संदेश प्राप्त करणे Node.js

लायब्ररी आयात करा kafkajs आणि Kafka Broker कॉन्फिगरेशन परिभाषित करा(आधी केले नसल्यास):

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

consumer विशिष्ट कडून संदेश प्राप्त करण्यासाठी एक तयार करा topic:

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 आणि लायब्ररी पहा. kafkajs