@fge-bo-nest/kafka

Integracion de Kafka para aplicaciones NestJS.

Requisitos minimos

• Node.js 18 o superior
• Yarn 1.22.x
• NestJS 10 u 11

Instalacion

yarn add @fge-bo-nest/kafka kafkajs uuid

Uso basico

import { KafkaService, MsKafkaModule, PriorityMessage } from '@fge-bo-nest/kafka';

Build local

Desde la raiz del monorepo:

yarn kafka:build

Desde este paquete:

yarn build

Publicacion

cd kafka
yarn publish

Notas

• El paquete exporta modulo, servicio, interfaces y constantes para consumo directo.
• Cada suscripcion crea un solo miembro por topic/grupo.
• concurrency y partitionsConsumedConcurrently controlan paralelismo entre particiones; no crean miembros adicionales.
• Los handlers largos mantienen heartbeat y solo hacen commit al finalizar.
• Los errores de handlers y productores se propagan; el caller decide su politica de reintento o DLQ.