0

我有一个 Nest.js 微服务应用程序。对于 MS 之间的消息代理,我使用的是 kafka。

现在我想在健康服务中注入这个相同的连接来测试它的状态。我不想创建新客户端和新连接。我需要在 main.ts 中创建的那个。

const microserviceOptions = {
  transport: Transport.KAFKA,
  options: {
    client: {
      clientId: `id`,
      brokers: [brokers],
    },
    consumer: {
      groupId: 'group-id',
    },
  },
};

理想情况下,我很想直接从 nestjs 获取 kafkajs 客户端,以创建生产者和消费者。

4

1 回答 1

0

如果有人一直在寻找这个。我将现有的 kafka transprot 策略扩展为自定义运输工具并将其导入。

我将 ServerKafka 扩展为一个新的类 CustomServerKafka。新类只有 getConsumer 和 getProducer,因为消费者和生产者在 ServerKafka 中受到保护。

我使用单例类创建者来访问活跃的消费者

于 2021-02-28T15:59:33.400 回答