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();  

Consumer ਕਦਮ 3: ਅੰਦਰ ਦੇ ਨਾਲ ਸੁਨੇਹੇ ਪ੍ਰਾਪਤ ਕਰਨਾ 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