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

czq61nw1  于 2023-04-05  发布在  Apache
关注(0)|答案(1)|浏览(119)

我试图用Kafka在NestJS中生成消息,但似乎ClientsModule的默认设置是开始消费一个主题,我在文档中看不到禁用它的方法。
已使用以下命令创建客户端:

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

在开始时,我从Kafka得到以下日志:

"message":"Consumer has joined the group"

即使我没有配置或请求它。
是否有方法禁用消费者连接?

mspsb9vt

mspsb9vt1#

要在不消耗的情况下启动nestjs Kafka,需要将producerOnlyMode选项作为true传递

相关问题