diff --git a/go/vt/vttablet/tabletmanager/vreplication/external_connector.go b/go/vt/vttablet/tabletmanager/vreplication/external_connector.go
index e5c49209418..3a48ff0a19f 100644
--- a/go/vt/vttablet/tabletmanager/vreplication/external_connector.go
+++ b/go/vt/vttablet/tabletmanager/vreplication/external_connector.go
@@ -90,7 +90,7 @@ func (ec *externalConnector) Get(name string) (*mysqlConnector, error) {
 	c.se = schema.NewEngine(c.env)
 	c.vstreamer = vstreamer.NewEngine(c.env, nil, c.se, "")
 	c.vstreamer.InitDBConfig("")
-	c.se.InitDBConfig(c.env.Config().DB.DbaWithDB())
+	c.se.InitDBConfig(c.env.Config().DB.AllPrivsWithDB())
 
 	// Open
 	if err := c.se.Open(); err != nil {