Use msgstream bufsize for mqclient initialization (#14406)

Signed-off-by: N Congqi Xia <congqi.xia@zilliz.com>

Use msgstream bufsize for mqclient initialization (#14406)
Signed-off-by: N Congqi Xia <congqi.xia@zilliz.com>
444fae87 · congqixia · GitHub · 9ad83fb9 · 444fae87
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

internal/msgstream/mq_msgstream.go internal/msgstream/mq_msgstream.go +2 -0

未找到文件。
--- a/internal/msgstream/mq_msgstream.go
+++ b/internal/msgstream/mq_msgstream.go
@@ -144,6 +144,7 @@ func (ms *mqMsgStream) AsConsumerWithPosition(channels []string, subName string,
 				SubscriptionName:            subName,
 				Type:                        mqclient.Exclusive,
 				SubscriptionInitialPosition: position,
+				BufSize:                     ms.bufSize,
 			})
 			if err != nil {
 				return err
@@ -714,6 +715,7 @@ func (ms *MqTtMsgStream) AsConsumerWithPosition(channels []string, subName strin
 				SubscriptionName:            subName,
 				Type:                        mqclient.Exclusive,
 				SubscriptionInitialPosition: position,
+				BufSize:                     ms.bufSize,
 			})
 			if err != nil {
 				return err