Me1onRind edited a comment on issue #183: 设置consumeMessageBatchMaxSize发现一个问题 URL: https://github.com/apache/rocketmq-client-go/issues/183#issuecomment-529989592 It isn't solve the problem. There is my simple demo: https://github.com/Me1onRind/rocketmq-demo You can keep comsumer.go running. Every time go run product.go, will send 10 messages. In my env, the consumer can't consume 10 messages every time and check the local offset.json, the offset is wrong. By the way, you need add consumeMessageBatchMaxSize in rocketmq-client-go's code(consumer/option.go). And when I restart consume.go, it still consume history messages. ```go func WithConsumeMessageBatchMaxSize(consumeMessageBatchMaxSize int) Option { return func(opts *consumerOptions) { opts.ConsumeMessageBatchMaxSize = consumeMessageBatchMaxSize } } ```
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
