开发者社区 > 云原生 > 消息队列 > 正文

消息队列RocketMQ版是否支持积压消息后批量消费?

消息队列RocketMQ版是否支持积压消息后批量消费?

展开
收起
Lee_tianbai 2021-01-01 16:19:59 1137 0
1 条回答
写回答
取消 提交回答
  • RocketMQ 现在的消费模式本身就是 push 的。 1. 批量消费可在消费客户端中设置 ConsumeMessageBatchMaxSize 参数, 批量消费消息个数。 批量拉取也要有对应的消息数才行,这个是在预期范围内的。这个是根据当时 队列有多少条消息未消费来决定的,并不能做到每次消费的消息是一个固定值。 PropertyKeyConst.ConsumeMessageBatchMaxSize 取值范围为 1-32。 mq 的消费逻辑是这样的,启动消费者之后,消费者会一直在线。 如果 topic 当中一直没有消息过来,我们会每 15 秒长轮询一次,消费者主动 到 topic 当中拉取消息。如果有消息,就会将消息拉取到进行消费。所以暂 时不支持挤压一定的消息之后再批量消费的。 2. 有序消息不支持批量消费。

    2021-01-01 16:20:27
    赞同 展开评论 打赏

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖多行业。

相关电子书

更多
消息队列 Kafka 版差异化特性 立即下载
消息队列kafka介绍 立即下载
Rocket MQ 使用排查指南 立即下载