உடன் நீடித்து நிலைத்தன்மை மற்றும் நிலைத்தன்மையை நிர்வகித்தல் Apache Kafka Node.js

நீடித்த தன்மையை நிர்வகித்தல்

பிரதி மற்றும் பகிர்வை உள்ளமைத்தல் Kafka: a ஐ உருவாக்கும் போது, ​​அதற்கான topic பகிர்வுகளின் எண்ணிக்கையை நீங்கள் குறிப்பிடலாம். இது ஒவ்வொன்றின் பிரதிகளின் எண்ணிக்கையாகும், ஒவ்வொரு செய்தியும் நகலெடுக்கப்படும் தரகர்களின் எண்ணிக்கையைத் தீர்மானிக்கிறது. topic replication factor replication factor partition

எடுத்துக்காட்டு: orders topic உங்களிடம் 3 பகிர்வுகள் மற்றும் 2 இல் ஒரு பகிர்வு உள்ளது என்று வைத்துக்கொள்வோம். replication factor இதன் பொருள் ஒவ்வொரு செய்தியும் 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.