Cross Kafka

O Cross Kafka encapsula toda a configuração e boilerplate necessários para integrar o KafkaJS em aplicações Express, oferecendo uma API simples e declarativa baseada na API do @nestjs/microservices.

O pacote lida automaticamente com reconexão, dead-letter queues e serialização de mensagens, permitindo que o desenvolvedor foque na lógica de negócio.

Suporta padrões emit/listen (fire-and-forget), send/subscribeFrom (requisição-resposta com timeout configurável) e encadeamento de middlewares semelhante ao Express.