apache-kafka - Nestjs中的NestFactory.create可以订阅kafka上的topic吗？

Question

文档建议使用 NestFactory.createMicroservice 创建传输订阅应用。

我目前有一个基于 REST 的微服务，其中包含领域逻辑和数据库连接。我想在该微服务上订阅 Kafka 消息。是否可以在这个单一微服务的范围内做到这一点？我在文档中看不到。

这让我想知道模式是否应该是:我应该使用 NestFactory.createMicroservice 创建一个额外的微服务，它将连接到 Kafka，然后将消息分发到我的 REST API ......通过 REST？这意味着 rest api 将在 rest 上发生所有可能的“操作”，但间歇性微服务将根据 Kafka 的消息触发它。

如果那是真的，这是否意味着随着我的应用程序扩展，我最终可能会为每个休息微服务提供一个 Kafka 订阅微服务？或者是否会有一个订阅微服务会触发多个 REST API？或者……这取决于用例？

Answer 1

可以在 nest 中连接两种方法 - 微服务和普通应用程序。文档没有提到它，但常见问题解答解释了如何制作 Hybrid application .

GRPC example在行动中展示它

import { NestFactory } from '@nestjs/core';
import { MicroserviceOptions } from '@nestjs/microservices';
import { AppModule } from './app.module';
import { grpcClientOptions } from './grpc-client.options';

async function bootstrap() {

  const app = await NestFactory.create(AppModule);
  app.connectMicroservice<MicroserviceOptions>(grpcClientOptions);

  await app.startAllMicroservicesAsync();
  await app.listen(3001);
  console.log(`Application is running on: ${await app.getUrl()}`);
}
bootstrap();

这样你就可以让rest api与kafka/rabbit/grpc连接