Nestjs中的NestFactory.create可以订阅kafka上的主题吗？

npm install @nestjs/microservices kafka-node

import { NestFactory } from '@nestjs/core';
import { MicroserviceOptions, Transport } from '@nestjs/microservices';

async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(AppModule, {
    transport: Transport.KAFKA,
    options: {
      client: {
        brokers: ['localhost:9092'], // Kafka broker地址
      },
      consumer: {
        groupId: 'my-group', // 消费者组ID
      },
    },
  });
  await app.listenAsync();
}
bootstrap();

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

@Controller()
export class KafkaController {
  @MessagePattern('my-topic') // 订阅名为'my-topic'的kafka主题
  async handleMessage(data: any) {
    // 处理接收到的消息
    console.log('Received message:', data);
  }
}

import { Module } from '@nestjs/common';
import { KafkaController } from './kafka.controller';

@Module({
  controllers: [KafkaController],
})
export class AppModule {}