सह टिकाऊपणा आणि सुसंगतता व्यवस्थापित करणे Apache Kafka Node.js

टिकाऊपणाचे व्यवस्थापन

मध्ये प्रतिकृती आणि विभाजन संरचीत करणे Kafka: एक तयार करताना topic, तुम्ही त्यासाठी विभाजनांची संख्या topic सोबत निर्दिष्ट करू शकता replication factor. replication factor प्रत्येक partition मेसेजची प्रतिकृती किती ब्रोकर्सवर केली जाईल हे निर्धारित करून प्रत्येकासाठी प्रतिकृतींची संख्या आहे .

उदाहरण: समजा तुमच्याकडे orders topic 3 विभाजने आणि replication factor 2 पैकी a आहे. याचा अर्थ प्रत्येक संदेशाची प्रतिकृती 2 वेगवेगळ्या ब्रोकरला केली जाईल. एखाद्याला broker अपयश आल्यास, तुम्ही अजूनही उर्वरित संदेशांमध्ये प्रवेश करू शकता broker.

सुसंगतता सुनिश्चित करणे

संदेश पाठवताना आणि प्राप्त करताना पोचपावती यंत्रणा: मध्ये Apache Kafka, अचूकता आणि टिकाऊपणा सुनिश्चित करण्यासाठी संदेश पाठवताना आणि प्राप्त करताना तुम्ही पोचपावती यंत्रणा वापरू शकता. ही यंत्रणा खात्री करते की तुम्ही पुढील कृतींसह पुढे जाण्यापूर्वी संदेश यशस्वीरित्या पाठवले गेले आहेत किंवा पोचले गेले आहेत.

उदाहरण: संदेश पाठवताना, तुम्ही acks पोचपावती कॉन्फिगरेशन निर्दिष्ट करण्यासाठी पर्याय वापरू शकता. उदाहरणार्थ, च्या acks: 1 नेत्याला संदेश यशस्वीरित्या पाठवला गेला आहे याची खात्री करते. पावतीची प्रतीक्षा करून, इतर कार्ये सुरू ठेवण्यापूर्वी संदेश केव्हा सुरक्षितपणे संग्रहित केला गेला आहे हे तुम्हाला कळेल. broker partition

const { Kafka } = require('kafkajs');  
  
const kafka = new Kafka({  
  clientId: 'your-client-id',  
  brokers: ['broker1:port1', 'broker2:port2'],  
});  
  
const producer = kafka.producer();  
  
const sendMessages = async() => {  
  await producer.connect();  
  await producer.send({  
    topic: 'your-topic',  
    messages: [{ value: 'Hello Kafka!' }],  
    acks: 1, // Acknowledge after the message is successfully sent  
  });  
  await producer.disconnect();  
};  
  
sendMessages();  

टीप:

• तुमच्या प्रकल्पाच्या वास्तविक माहितीसह 'your-client-id', 'broker1:port1', , आणि इतर मूल्ये बदलण्याची खात्री करा. 'your-topic'
• विशिष्ट प्रकल्प आवश्यकतांनुसार कॉन्फिगरेशन पर्याय आणि पोचपावती यंत्रणा बदलू शकतात.

Apache Kafka विभाजन, प्रतिकृती कॉन्फिगर करून, पावती यंत्रणा आणि प्रतिकृती पर्याय वापरून, तुम्ही वापरताना टिकाऊपणा आणि सुसंगतता सुनिश्चित करू शकता Node.js.