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