ਪ੍ਰੋਜੈਕਟ 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