[GitHub] [rocketmq-client-go] Me1onRind commented on issue #183: 设置consumeMessageBatchMaxSize发现一个问题

[GitBox <gi...@apache.org>]

Me1onRind commented 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).
   ```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:
users@infra.apache.org


With regards,
Apache Git Services