[rocketmq-client-go] branch master updated: make consumeMessageBatchMaxSize default value consistent with java client (#660)

[wenfeng]

This is an automated email from the ASF dual-hosted git repository.

wenfeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new a7a7387  make consumeMessageBatchMaxSize default value consistent with 
java client (#660)
a7a7387 is described below

commit a7a73875c91957ef595544cbaef3aa3dd1e11657
Author: 张旭 <maixiaoha...@gmail.com>
AuthorDate: Thu Jul 15 15:16:51 2021 +0800

    make consumeMessageBatchMaxSize default value consistent with java client 
(#660)
    
    Co-authored-by: zhangxu16 <zhangx...@xiaomi.com>
---
 consumer/push_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index efd373f..ec44a1e 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -501,7 +501,7 @@ func (pc *pushConsumer) validate() {
 
        if pc.option.ConsumeMessageBatchMaxSize < 1 || 
pc.option.ConsumeMessageBatchMaxSize > 1024 {
                if pc.option.ConsumeMessageBatchMaxSize == 0 {
-                       pc.option.ConsumeMessageBatchMaxSize = 512
+                       pc.option.ConsumeMessageBatchMaxSize = 1
                } else {
                        rlog.Error("option.ConsumeMessageBatchMaxSize out of 
range [1, 1024]", nil)
                }