RocketMQ 怎么合理设置消费并行度?

绝大部分消息消费行为都属于 IO 密集型,即可能是操作数据库,或者调用 RPC,这类消费行为的消费速度在于后端数据库或者外系统的吞吐量通过增加消费并行度,可以提高总的消费吞吐量,但是并行度增加到一定程度,反而会下降。
所以,应用必须要设置合理的并行度。
如下有几种修改消费并行度的方法。

  • 同一个 ConsumerGroup 下通过增加Consumer 实例数量来提高并行度,可以通过加机器,或者在已有机器启动多个进程的方式
  • 提高单个 Consumer 的消费并行线程

发表评论

后才能评论