Marthanacht a Bhainistiú & Comhsheasmhacht le in Apache Kafka Node.js

Marthanacht a Bhainistiú

Macasamhlú agus Deighilt a Chumrú i Kafka: Agus tú ag cruthú topic, is féidir leat líon na ndeighiltí dó sin a shonrú topic in éineacht leis an replication factor. Is replication factor é an líon macasamhla do gach ceann acu partition, ag cinneadh líon na bróicéirí a ndéanfar gach teachtaireacht a mhacasamhlú dóibh.

Sampla: Ligean le rá go bhfuil orders topic 3 dheighiltí agat agus ceann replication factor de 2 agat. Ciallaíonn sé seo go ndéanfar gach teachtaireacht a mhacasamhlú chuig 2 bhróicéir éagsúla. Sa chás broker go dteipeann ar dhuine amháin, is féidir leat rochtain a fháil fós ar na teachtaireachtaí ón leathanach broker.

Comhsheasmhacht a Chinntiú

Meicníocht Admhála agus Teachtaireachtaí á Seol agus á Fáil: In Apache Kafka, is féidir leat an meicníocht admhála a úsáid agus tú ag seoladh agus ag fáil teachtaireachtaí chun cruinneas agus marthanacht a chinntiú. Cinntíonn an meicníocht seo go seoltar teachtaireachtaí go rathúil nó go n-admhaítear iad sula dtéann tú ar aghaidh le tuilleadh gníomhartha.

Sampla: Nuair a bhíonn teachtaireachtaí á seoladh agat, is féidir leat an acks rogha a úsáid chun an chumraíocht admhála a shonrú. Mar shampla, acks: 1 cinntíonn sé go bhfuil an teachtaireacht seolta go rathúil chuig ceannaire broker an partition. Trí fanacht ar admháil, beidh a fhios agat nuair a bheidh teachtaireacht stóráilte go sábháilte sula leanann tú ar aghaidh le tascanna eile.

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

Nóta:

  • Déan cinnte faisnéis iarbhír do thionscadail a chur in ionad 'your-client-id', 'broker1:port1', agus luachanna eile. 'your-topic'
  • Féadfaidh roghanna cumraíochta agus meicníochtaí admhála a bheith éagsúil ag brath ar riachtanais shonracha an tionscadail.

Trí dheighilt, macasamhlú, meicníochtaí admhála agus roghanna macasamhlaithe a chumrú, is féidir leat Marthanacht a bhainistiú go héifeachtach agus Comhsheasmhacht a Chinntiú agus tú ag Apache Kafka úsáid Node.js.