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

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

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

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

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系列产品 Serverless 化。RocketMQ 中文社区:https://rocketmq-learning.com/

还有其他疑问?
咨询AI助理