diff --git a/docs/developer_guides/chap05_proxy.md b/docs/developer_guides/chap05_proxy.md
index f075b1acbf..929ea45303 100644
--- a/docs/developer_guides/chap05_proxy.md
+++ b/docs/developer_guides/chap05_proxy.md
@@ -395,10 +395,6 @@ type GlobalParamsTable struct {
 	ProxySubName                       string
 	ProxyTimeTickChannelNames          []string
 	DataDefinitionChannelNames         []string
-	MsgStreamInsertBufSize             int64
-	MsgStreamSearchBufSize             int64
-	MsgStreamSearchResultBufSize       int64
-	MsgStreamSearchResultPulsarBufSize int64
 	MsgStreamTimeTickBufSize           int64
 	MaxNameLength                      int64
 	MaxFieldNum                        int64
diff --git a/internal/proxynode/paramtable.go b/internal/proxynode/paramtable.go
index 329c754130..f201619b78 100644
--- a/internal/proxynode/paramtable.go
+++ b/internal/proxynode/paramtable.go
@@ -45,25 +45,21 @@ type ParamTable struct {
 	MasterAddress string
 	PulsarAddress string
 
-	QueryNodeNum                       int
-	QueryNodeIDList                    []UniqueID
-	ProxyID                            UniqueID
-	TimeTickInterval                   time.Duration
-	K2SChannelNames                    []string
-	SearchChannelNames                 []string
-	SearchResultChannelNames           []string
-	ProxySubName                       string
-	ProxyTimeTickChannelNames          []string
-	MsgStreamInsertBufSize             int64
-	MsgStreamSearchBufSize             int64
-	MsgStreamSearchResultBufSize       int64
-	MsgStreamSearchResultPulsarBufSize int64
-	MsgStreamTimeTickBufSize           int64
-	MaxNameLength                      int64
-	MaxFieldNum                        int64
-	MaxDimension                       int64
-	DefaultPartitionName               string
-	DefaultIndexName                   string
+	QueryNodeNum              int
+	QueryNodeIDList           []UniqueID
+	ProxyID                   UniqueID
+	TimeTickInterval          time.Duration
+	K2SChannelNames           []string
+	SearchChannelNames        []string
+	SearchResultChannelNames  []string
+	ProxySubName              string
+	ProxyTimeTickChannelNames []string
+	MsgStreamTimeTickBufSize  int64
+	MaxNameLength             int64
+	MaxFieldNum               int64
+	MaxDimension              int64
+	DefaultPartitionName      string
+	DefaultIndexName          string
 
 	PulsarMaxMessageSize int
 	Log                  log.Config
@@ -148,10 +144,6 @@ func (pt *ParamTable) initParams() {
 	pt.initK2SChannelNames()
 	pt.initProxySubName()
 	pt.initProxyTimeTickChannelNames()
-	pt.initMsgStreamInsertBufSize()
-	pt.initMsgStreamSearchBufSize()
-	pt.initMsgStreamSearchResultBufSize()
-	pt.initMsgStreamSearchResultPulsarBufSize()
 	pt.initMsgStreamTimeTickBufSize()
 	pt.initMaxNameLength()
 	pt.initMaxFieldNum()
@@ -240,22 +232,6 @@ func (pt *ParamTable) initProxyTimeTickChannelNames() {
 	pt.ProxyTimeTickChannelNames = []string{prefix}
 }
 
-func (pt *ParamTable) initMsgStreamInsertBufSize() {
-	pt.MsgStreamInsertBufSize = pt.ParseInt64("proxyNode.msgStream.insert.bufSize")
-}
-
-func (pt *ParamTable) initMsgStreamSearchBufSize() {
-	pt.MsgStreamSearchBufSize = pt.ParseInt64("proxyNode.msgStream.search.bufSize")
-}
-
-func (pt *ParamTable) initMsgStreamSearchResultBufSize() {
-	pt.MsgStreamSearchResultBufSize = pt.ParseInt64("proxyNode.msgStream.searchResult.recvBufSize")
-}
-
-func (pt *ParamTable) initMsgStreamSearchResultPulsarBufSize() {
-	pt.MsgStreamSearchResultPulsarBufSize = pt.ParseInt64("proxyNode.msgStream.searchResult.pulsarBufSize")
-}
-
 func (pt *ParamTable) initMsgStreamTimeTickBufSize() {
 	pt.MsgStreamTimeTickBufSize = pt.ParseInt64("proxyNode.msgStream.timeTick.bufSize")
 }
diff --git a/internal/proxynode/proxy_node.go b/internal/proxynode/proxy_node.go
index b4ecd0714a..061982bccb 100644
--- a/internal/proxynode/proxy_node.go
+++ b/internal/proxynode/proxy_node.go
@@ -156,9 +156,8 @@ func (node *ProxyNode) Init() error {
 	//}
 
 	m := map[string]interface{}{
-		"PulsarAddress":  Params.PulsarAddress,
-		"ReceiveBufSize": Params.MsgStreamSearchBufSize,
-		"PulsarBufSize":  1024}
+		"PulsarAddress": Params.PulsarAddress,
+		"PulsarBufSize": 1024}
 	err = node.msFactory.SetParams(m)
 	if err != nil {
 		return err