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

შექმენით A 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 ბიბლიოთეკას, რომ გაიგოთ მეტი კონფიგურაციის ვარიანტებისა და ფუნქციონალობის შესახებ.