How to set up Kafka transport in NestJS microservices for event-driven scaling?

NestJS supports Kafka via @nestjs/microservices with Transporters.KAFKA. Configure MicroserviceOptions with brokers, consumer groups, and topics; use @MessagePattern() for handlers. Scales to 10k+ TPS with partitioning.

Example:-

Code

// main.ts
await NestFactory.createMicroservice(AppModule, {
  transport: Transport.KAFKA,
  options: { client: { brokers: ['localhost:9092'] } }
});