NestJS Kafka客户端:如何禁用默认启动的消费者?
在NestJS中禁用Kafka客户端默认创建的消费者
NestJS的Kafka客户端底层基于kafkajs,默认初始化消费者是因为ClientProxy的设计默认兼顾生产与消费场景。要禁用消费者连接,可通过在配置中添加consumer: { run: false }实现:
修改你的客户端创建代码,补充对应配置项:
return ClientProxyFactory.create({ transport: Transport.KAFKA, options: { ...kafkaOptions, consumer: { run: false, }, }, });
配置后,客户端只会初始化生产者,不会启动消费者加入消费组。后续若需启用消费功能,将run值改回true并配置对应消费主题即可。
内容的提问来源于stack exchange,提问作者user17714968
相关产品推荐
相关产品推荐

