RocketMQ消费批拉超过32不生效
2024-08-27 17:24:28
由于一些原因,我需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:
为了简单验证是否正确,消费如下:
直接通过打印msgs.size()观察情况即可。
现象
实验的topic里面的消息数量很多很多,但是启动消费端,消费端的日志如下:
奇怪啦,明明已经进行了修改
为什么还是每次只能消费32条呢?
调试RocketMQ源码
通过跟踪consumer代码:
这里的确已经设置为400了,那么我们需要跟踪到broker服务端进行查看了。
broker接受到的也是400,我们只有继续跟踪
因为返回为true导致下面的if判断成立,for循环就break了,所有只取了32条数据返回到consumer了:
如果需要让可以一次拉取400条,需要修改broker这里的数据配置才可(其实关于一条消息大小也是类似的,虽然说最大设置16M,但是也是和这里同理需要设置broker相关的数据配置才可生效)。
修改broker的配置文件,添加:maxTransferCountOnMessageInMemory=400 重启broker即可,效果如下:
效果正常,其实如果消息过大,还需要考虑下面几个参数:
备注:也可以不用重启broker,通过命令实时修改:
sh mqadmin updateBrokerConfig -c 集群名称 -n namesrv -k maxTransferCountOnMessageInMemory -v 400
总结
需要RocketMQ消费的时候,一批拉400条,一批处理400条。设置如下:
还是达不到效果的,还需要设置broker相关的参数,本次里面设置broker的maxTransferCountOnMessageInMemory=400即可,其他情况需要考虑如下等参数。
本文转载自http://www.jiangxinlingdu.com/rocketmq/2018/12/05/pullbatchsize.html
最新文章
- observejs改善组件编程体验
- 2016shenyang-1002-HDU5893-List wants to travel-树链剖分+线段树维护不同区间段个数
- sql 循环某段时间的每一天
- NetBPM的安装 -转
- Java入门知识点:
- centos6.4 网络适配器设置仅主机模式
- 转-问自己:UI设计注意的十个问题
- 暑假集训(4)第三弹 -----递推(Hdu1799)
- Spark机器学习笔记一
- LNMP状态管理命令
- java基础(六) switch语句的深入解析
- css-方形边框四角
- SpringMVC源码学习之request处理流程
- python学习-名字管理
- (O)web缓存
- [PHP] 看博客学习插入排序
- Java 公历转农历,然后农历减一年(或者几天或者任意天),再把这个日期转成公历
- hibernate4.3 无法获取数据库最新值
- python 编码方式大全 fr = open(filename_r,encoding='cp852')
- python 爬虫的一些使用技巧