Apache Kafka உடன் செய்திகளை அனுப்புதல் & பெறுதல் Node.js

படி 1: காஃப்கா நூலகத்தை நிறுவவும் Node.js

terminal உங்கள் Node.js திட்டக் கோப்பகத்தில் a திறக்கவும் .

நூலகத்தை நிறுவ பின்வரும் கட்டளையை இயக்கவும் 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