commit a7a73875c91957ef595544cbaef3aa3dd1e11657
author 张旭 <maixiaohai00@gmail.com> Thu Jul 15 15:16:51 2021 +0800
committer GitHub <noreply@github.com> Thu Jul 15 15:16:51 2021 +0800
tree 7ab757374f5fd977a207215b82224c736973866b
parent e94bf49362a714350afb50536dcda5b7f5811ee9

make consumeMessageBatchMaxSize default value consistent with java client (#660)

Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>

consumer/push_consumer.go

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 @@
 
 	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)
 		}