NestJS: Kafka客户端-禁用消费者

Question

我试图用kafka在NestJS中生成消息，但似乎ClientsModule的默认设置是开始消费一个主题，我在文档中看不到禁用它的方法。

创建客户端:

return ClientProxyFactory.create({
transport: Transport.KAFKA,
options: kafkaOptions,
});

在启动时，我从kafka获得以下日志:

"message":"Consumer has joined the group"

即使我没有配置或请求它。

是否有禁用消费者连接的方法?

Answer 1

要启动nestjs kafka而不消耗你需要传递producerOnlyMode选项作为true