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