Usage no npm install needed!

<script type="module">
  import nestjsEventStoreCqrs from 'https://cdn.skypack.dev/nestjs-event-store-cqrs';
</script>

README

NestJS Kafka Event Store CQRS

A progressive Node.js framework for building efficient and scalable server-side applications.

Description

A lightweight KafkaJS event-store module for CQRS Nest framework (node.js). It requires @nestjs/cqrs and kafkajs

Installation

$ npm install --save nestjs-event-store-cqrs
$ npm install --save kafkajs

Quick Start

import { Module } from '@nestjs/common';
import { CqrsModule } from '@nestjs/cqrs';
import { EventStoreModule } from 'nestjs-event-store-cqrs';

@Module({
  imports: [
    CqrsModule,
    EventStoreModule.forRoot({
      client: {
        clientId: 'hero',
        brokers: ['localhost:9092'],
      },
      consumer: {
        groupId: 'hero-consumer',
      },
      eventHandlers: {
        HeroKilledDragonEvent: (data) => new HeroKilledDragonEvent(data),
      },
    }),
  ]
})
export class AppModule {}

FULL EXAMPLE