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