make consumeMessageBatchMaxSize default value consistent with java cl…

…ient (#660) Co-authored-by: zhangxu16 <[email protected]>
apache · Jul 15, 2021 · a7a7387 · a7a7387
1 parent e94bf49
commit a7a7387
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 		}