You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.26 10:11:59