@allinmkt/kafka v1.4.7

KAFKA ALLIN

Este módulo é um envelopamento do KafkaJS desenvolvido para os producers e consumers do projeto Synapse. Engloba toda a parte de configuração,instanciamento e disponibilização do cliente Kafka, fazendo assim com que pouca configuração seja necessária.

Instruções

Instalação

yarn add @allinmkt/kafka
ou
npm install --save @allinmkt/kafka

Definindo um produtor

Variáveis de ambiente

NODE_ENV=develop
KAFKA_CLIENT_ID=consumer-client-id
KAFKA_BROKERS=HOST:PORT,HOST:PORT

Exemplo

import { KafkaAllin } from "@allinmkt/kafka";

const kafka = new KafkaAllin();
await kafka.setProducer();

const toSend = {
  flow: ['topic1', 'topic2'],
  data: {
    // seus dados
  }
};

const result = await kafka.producerSend(toSend);

Definindo um consumidor

Variáveis de ambiente

NODE_ENV=develop
KAFKA_CLIENT_ID=consumer-client-id
KAFKA_BROKERS=HOST:PORT,HOST:PORT
KAFKA_GROUP_ID=name
KAFKA_TOPIC=name

Exemplo

import { KafkaAllin } from "@allinmkt/kafka";

async function init() {
  const kafka = new KafkaAllin();
  await kafka.setConsumer();
  await kafka.consumerRun(
    async (payload: EachMessagePayload, next: Function) => {
      try {
        const { value } = payload.message as any;
        console.log('MESSAGE', value);
        next(value);
      } catch (error) {
        console.log('ERROR', error);
      }
    }
  );
}

init();