我试图用Kafka在NestJS中生成消息,但似乎ClientsModule
的默认设置是开始消费一个主题,我在文档中看不到禁用它的方法。
已使用以下命令创建客户端:
return ClientProxyFactory.create({
transport: Transport.KAFKA,
options: kafkaOptions,
});
在开始时,我从Kafka得到以下日志:
"message":"Consumer has joined the group"
即使我没有配置或请求它。
是否有方法禁用消费者连接?
1条答案
按热度按时间mspsb9vt1#
要在不消耗的情况下启动nestjs Kafka,需要将
producerOnlyMode
选项作为true
传递