Ar naudojote Apache Kafka savo projektuose ar darbo užduotyje?

Taip, Node.js projektuose naudoju Apache Kafka, kad organizuočiau žinučių mainus tarp mikroservisų. Kafka leidžia efektyviai apdoroti didelius duomenų srautus realiuoju laiku, užtikrinant aukštą našumą ir patikimumą.

Pavyzdys, kaip naudoti Kafka Node.js su biblioteka kafkajs:

const { Kafka } = require('kafkajs');

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['kafka-broker1:9092', 'kafka-broker2:9092']
});

const producer = kafka.producer();

async function sendMessage() {
  await producer.connect();
  await producer.send({
    topic: 'test-topic',
    messages: [
      { value: 'Labas, Kafka!' }
    ]
  });
  await producer.disconnect();
}

sendMessage().catch(console.error);

Šis požiūris padeda kurti mastelį ir atsparias sistemas.