如何在NestJS中同时配置Kafka微服务与Fastify REST端点？

云上老周

2026-8-19

在同一个NestJS服务中同时启用Fastify REST端点与Kafka微服务

完全可以在同一个NestJS服务中同时运行Fastify REST接口和Kafka微服务，NestJS原生支持这种混合服务模式，不需要二选一。你只需要先创建HTTP应用实例，再通过connectMicroservice方法挂载Kafka微服务配置，最后同时启动两者即可。

完整配置代码示例

import { NestFactory } from '@nestjs/core';
import { NestFastifyApplication, FastifyAdapter } from '@nestjs/platform-fastify';
import { Transport, MicroserviceOptions } from '@nestjs/microservices';
import { AppModule } from './app.module';

async function bootstrap() {
  // 初始化Fastify应用
  const app = await NestFactory.create<NestFastifyApplication>(
    AppModule,
    new FastifyAdapter(),
    { bufferLogs: true }
  );

  // 挂载Kafka微服务配置
  app.connectMicroservice<MicroserviceOptions>({
    transport: Transport.KAFKA,
    options: {
      client: {
        brokers: ['localhost:9092'],
      },
    },
  });

  // 同时启动HTTP服务器和所有微服务
  await app.startAllMicroservices();
  await app.listen(3000); // Fastify监听的端口，可根据需求修改
}
bootstrap();

控制器使用示例

在同一个控制器中，你可以同时定义REST路由和Kafka消息处理器，两者互不干扰：

import { Controller, Get } from '@nestjs/common';
import { MessagePattern } from '@nestjs/microservices';

@Controller('products')
export class ProductsController {
  // REST接口：GET /products
  @Get()
  getProducts() {
    return [{ id: 1, name: 'Sample Product' }];
  }

  // Kafka消息处理器：监听"product.updated"主题
  @MessagePattern('product.updated')
  handleProductUpdate(data: any) {
    console.log('收到Kafka消息:', data);
    return { code: 0, msg: '消息处理完成' };
  }
}