RocketMQ消费批拉超过32不生效

栏目: 后端 · 发布时间: 6年前

内容简介:由于一些原因,我需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:为了简单验证是否正确,消费如下:

说明

由于一些原因,我需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:

RocketMQ消费批拉超过32不生效

为了简单验证是否正确,消费如下:

RocketMQ消费批拉超过32不生效

直接通过打印msgs.size()观察情况即可。

现象

实验的topic里面的消息数量很多很多,但是启动消费端,消费端的日志如下:

RocketMQ消费批拉超过32不生效

奇怪啦,明明已经进行了修改

RocketMQ消费批拉超过32不生效

为什么还是每次只能消费32条呢?

调试RocketMQ源码

通过跟踪consumer代码:

RocketMQ消费批拉超过32不生效

这里的确已经设置为400了,那么我们需要跟踪到broker服务端进行查看了。

RocketMQ消费批拉超过32不生效

broker接受到的也是400,我们只有继续跟踪

RocketMQ消费批拉超过32不生效

因为返回为true导致下面的if判断成立,for循环就break了,所有只取了32条数据返回到consumer了:

RocketMQ消费批拉超过32不生效

RocketMQ消费批拉超过32不生效

如果需要让可以一次拉取400条,需要修改broker这里的数据配置才可(其实关于一条消息大小也是类似的,虽然说最大设置16M,但是也是和这里同理需要设置broker相关的数据配置才可生效)。

修改broker的配置文件,添加:maxTransferCountOnMessageInMemory=400 重启broker即可,效果如下:

RocketMQ消费批拉超过32不生效

效果正常,其实如果消息过大,还需要考虑下面几个参数:

RocketMQ消费批拉超过32不生效

总结

需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:

RocketMQ消费批拉超过32不生效

还是达不到效果的,还需要设置broker相关的参数,本次里面设置broker的maxTransferCountOnMessageInMemory=400即可,其他情况需要考虑如下等参数。

RocketMQ消费批拉超过32不生效

文章github源代码地址: rocketmq ,或者公号回复“ rocketmq ”获取源码地址。


以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

征服C指针

征服C指针

前桥和弥 / 吴雅明 / 人民邮电出版社 / 2013-2 / 49.00元

《图灵程序设计丛书:征服C指针》被称为日本最有营养的C参考书。作者是日本著名的“毒舌程序员”,其言辞犀利,观点鲜明,往往能让读者迅速领悟要领。书中结合了作者多年的编程经验和感悟,从C语言指针的概念讲起,通过实验一步一步地为我们解释了指针和数组、内存、数据结构的关系,展现了指针的常见用法,揭示了各种使用技巧。另外,还通过独特的方式教会我们怎样解读C语言那些让人“纠结”的声明语法,如何绕过C指针的陷阱......一起来看看 《征服C指针》 这本书的介绍吧!

XML 在线格式化
XML 在线格式化

在线 XML 格式化压缩工具

UNIX 时间戳转换
UNIX 时间戳转换

UNIX 时间戳转换

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具