apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.29k stars 415 forks source link

请问ConsumeMessageBatchMaxSize参数保证每次消费条数吗? #1066

Closed gzlboy closed 1 year ago

gzlboy commented 1 year ago

为何我设置成>1的数,但每次获取到的都是一条?

francisoliverlee commented 1 year ago

it works as i tested. ConsumeMessageBatchMaxSize should be 1 <= ConsumeMessageBatchMaxSize <= 1024

cserwen commented 1 year ago

这个值只限制获取到的最大数量,并不保证每次获取到指定条数

bogerv commented 5 months ago

这个值只限制获取到的最大数量,并不保证每次获取到指定条数

后面有定位到什么原因吗, 我也有遇到相同的问题, 设置ConsumeMessageBatchMaxSize, 但是消费的时候总是1条数据