From a7a73875c91957ef595544cbaef3aa3dd1e11657 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=97=AD?= Date: Thu, 15 Jul 2021 15:16:51 +0800 Subject: [PATCH] make consumeMessageBatchMaxSize default value consistent with java client (#660) Co-authored-by: zhangxu16 --- 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 efd373f0..ec44a1e3 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) }