diff --git a/internal/msgstream/rmqms/factory.go b/internal/msgstream/rmqms/factory.go
index 17cc28d82edfd40678f910018e3ddb47021200d4..462978b95a4ef4500f141b3affe175da71485b49 100644
--- a/internal/msgstream/rmqms/factory.go
+++ b/internal/msgstream/rmqms/factory.go
@@ -35,8 +35,8 @@ func (f *Factory) NewTtMsgStream(ctx context.Context) (msgstream.MsgStream, erro
 func NewFactory() msgstream.Factory {
 	f := &Factory{
 		dispatcherFactory: msgstream.ProtoUDFactory{},
-		ReceiveBufSize:    64,
-		RmqBufSize:        64,
+		ReceiveBufSize:    1024,
+		RmqBufSize:        1024,
 	}
 
 	rocksmq.InitRocksMQ("/tmp/milvus_rdb")