我有一个 Nest.js 微服务应用程序。对于 MS 之间的消息代理,我使用的是 kafka。
现在我想在健康服务中注入这个相同的连接来测试它的状态。我不想创建新客户端和新连接。我需要在 main.ts 中创建的那个。
const microserviceOptions = {
transport: Transport.KAFKA,
options: {
client: {
clientId: `id`,
brokers: [brokers],
},
consumer: {
groupId: 'group-id',
},
},
};
理想情况下,我很想直接从 nestjs 获取 kafkajs 客户端,以创建生产者和消费者。